Comment annuler un thread IO en cours d'exécution?

Version imprimable

Je ne parviens pas à annuler un Thread d'écriture dans une boucle de fichiers Image.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
// ....
Thread t = new Thread(new Runnable() { public void run() {
       try {
               for(Iterator writers = ImageIO.getImageWritersByMIMEType(conversion); writers.hasNext();) {
                      ImageWriter w = (ImageWriter)writers.next(); //cache.buffer(w);
                      w.setOutput(ios = new FileImageOutputStream(outputFile)); //cache.buffer(ios);
                      w.write(bimg);
                      w.dispose();
                      ios.close();
               }
            } catch(IOException ex) { 
               ex.printStackTrace();        
               JOptionPane.showMessageDialog(ImageMultiConverter.this, "An unknown error has occured while writing." + ex.getMessage()); }
}); 
t.start();

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
cancel = new JButton("Cancel");
        cancel.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) {
            switch(JOptionPane.showConfirmDialog(StatusPane.this, "Cancel all?")) {
                case JOptionPane.CANCEL_OPTION:
                    break;
                case JOptionPane.YES_OPTION:
                    synchronized(activeThreads){
                        for(Iterator i = activeThreads.values().iterator(); i.hasNext();) {
                            Thread t = (Thread)i.next();
                            boolean locked = true;
                            while(locked && t.isAlive()) {
                                try{ 
                                    t.checkAccess(); // l'exception n'est pas levée ???
                                    t.interrupt(); // ici le compilateur passe une fois sans réussir à arreter le thread !
                                    locked = false;
                                } catch(SecurityException ex) { 
                                    locked = true; 
                                } 
                            }
                        }
                    }
                    break;
                default:
            }
        }});

Quelqu'un a-t-il une solution pour interrompre une écriture en cours sur la sortie fichier? 8O

15/02/2007, 08h18
gifffftane
Deux solutions :
- J'ai l'impression que tu écris toute ton image d'un coup. Tu peux l'écrire petit à petit (100 ou 1.000 octets à la fois), et à chaque fois tu testes si ton thread a été interrompu par interrupt. Et s'il a été interrompu, tu arrêtes tranquillement ton écriture.
- Ou alors, depuis le thread avec JButton, tu fermes sans état d'âme le flux d'écriture de l'image.
15/02/2007, 19h07
broumbroum

Jai!

merci, c'est une bonne solution. MAis je ne trouve pas de méthode d'écriture différente avec ImageIO. par ici la doc donne write(Image) c'est tout.:roll:

Erratum: j'ai trouvé chez JAI un FileChannel que je cherchais. OK!
16/02/2007, 03h03
broumbroum

Ouais mais en fait c'est pas idéal... Je n'arrive pas à lancer une instance JAI. Quelqu'un sait-il utiliser cette API?:roll:

A propos de la 2e solution: interrompre un processus I/O (en Anglais)
16/02/2007, 08h51
STB_Fk

Bonjour,

pour stopper un thread tu peux faire un :

Code:

this.stop();

seul problème, tu vas avoir des warning depreciated :oops: en fonction de la jdk que tu utilise, mais ca fonctionne très bien.

Fk

Salut,

Citation:

Envoyé par STB_Fk

seul problème, tu vas avoir des warning depreciated :oops: en fonction de la jdk que tu utilise, mais ca fonctionne très bien.

Non non et non ! Si c'est deprecated c'est qu'il y a une raison : en stoppant brutalement ton thread, ton application peut se retrouver dans un état incorrect...

La solution la plus propre pour stopper un thread est d'utiliser interrupt() et de vérifier sa valeur. Pour les IO il faut passer par NIO et les interruptibles channels, ou bien d'utiliser un filtre qui vérifiera le status du thread. Par exemple pour un OutputStream :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 public class InterruptibleOutputStream extends FilterOutputStream { public InterruptibleOutputStream(OutputStream out) { super(out); } private void checkInterruptibleStatus() throws InterruptedIOException { if (Thread.interrupted()) { throw new InterruptedIOException("Interrupted"); } } @Override public void write(byte[] b, int off, int len) throws IOException { checkInterruptibleStatus(); super.write(b, off, len); } @Override public void write(byte[] b) throws IOException { checkInterruptibleStatus(); super.write(b); } @Override public void write(int b) throws IOException { checkInterruptibleStatus(); super.write(b); } }
Que tu utilises pour englober ton outputstream :
Code:

1 2 3 4 5 6 7 OutputStream os = new InterruptibleOutputStream( new FileOutputStream("file") ); try { // écrire sur le flux ! } finally { os.close(); }
a++

fix

juste pour bien confirmer la solution FileChannel de JAI proposée sur une page citée plus haut: il existe bien une classe RandomAccessFile qui renvoie un channel en lecture + écriture compatible avec JAI. merci pour vos réponses!:yaisse2:

Code:

1
2
3
4
5
6
7
8
9
10
11
 try {
            for(Iterator writers = ImageIO.getImageWritersByMIMEType(conversion); writers.hasNext();) {
               ImageWriter w = (ImageWriter)writers.next(); cache.buffer(w);
               RandomAccessFile raf = new RandomAccessFile(outputFile, "rws"); cache.buffer(raf);
               w.setOutput(ios = new FileChannelImageOutputStream(raf.getChannel())); cache.buffer(ios);
               toggleStep.addActiveStream((Closeable)raf);
               w.write(bimg);
               w.dispose();
               ios.close();
           }
         } catch(IOException ex) { ex.printStackTrace(); JOptionPane.showMessageDialog(ImageMultiConverter.this, "An unknown error has occured while writing." + ex.getMessage()); break; }