Faire attendre un Thread jusqu'à la fin d'un autre

**Mr.Robot12** · 25/01/2018, 12h08

Bonjour,
je reviens vers vous à nouveau car j'ai un problème.
comme l'indique le titre je voudrais qu'un Thread attend la fin d'un autre.
je m'explique :
j'ai une fonction d'extraction d'archives qui est lancée depuis un thread :

Code JAVA :

Sélectionner tout - Visualiser dans une fenêtre à part

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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
    public synchronized void extraireToutZip() {
        byte[] buffer = new byte[1024];
 
        try {
            final Collection<File> all = new ArrayList<File>();
            findFilesRecursively(new File("C:\\Users\\moi\\Desktop\\bilans batch satelit 2016"), all, ".zip");
 
            for (File file : all) {
                System.out.println(file.getName());
                ZipInputStream zis = new ZipInputStream(new FileInputStream(file));
                ZipEntry ze = zis.getNextEntry();
                while (ze != null) {
                    String fileName = ze.getName();
                    File newFile = new File(file.getParentFile() + File.separator + fileName);
 
                    // je vérifie si le fichier existe déjà pour ne pas l'extraire à nouveau
                    while (!newFile.getAbsoluteFile().exists()) {
                        System.out.println("Extraction du fichier : " + newFile.getAbsoluteFile());
                        if (ze.isDirectory()) {
                            String temp = newFile.getCanonicalPath();
                            new File(temp).mkdir();
                        }
                        else {
                            FileOutputStream fos = new FileOutputStream(newFile);
                            int len;
                            while ((len = zis.read(buffer)) > 0) {
                                fos.write(buffer, 0, len);
                            }
                            fos.close();
                        }
                        break;
                    }
                    /*else {
                        System.out.println("Déjà extraite !");
                        break;
                    }*/
                    ze = zis.getNextEntry();
                }
                zis.closeEntry();
                zis.close();
                System.out.println("Extraction complétée");
            }
        }
        catch (IOException ex) {
            ex.printStackTrace();
        }
    }

et une fonction qui lis les fichiers extraites, lancée depuis un Thread aussi:

Code JAVA :

Sélectionner tout - Visualiser dans une fenêtre à part

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
32
33
 
    public synchronized void lireTout() throws IOException
    {
        ArrayList<String> allFiles = new ArrayList<String>();
        listeRepertoire(new File("C:\\Users\\moi\\Desktop\\bilans batch satelit 2016"), allFiles);
 
        try
        {
            File f;
            FileReader fr;
            BufferedReader br;
            for (String file : allFiles)
            {
                f = new File(file);
                fr = new FileReader(f);
                br = new BufferedReader(fr);
                System.out.println(f.getAbsolutePath());
                String ligne = br.readLine();
                while (ligne != null)
                {
                    //System.out.println(ligne);
                    ligne = br.readLine();
                }
                // ligne = br.readLine();
                br.close();
                fr.close();
            }
        }
        catch (IOException exception)
        {
            System.out.println("Erreur lors de la lecture : " + exception.getMessage());
        }
    }

j'ai jamais fais de Thread du coup j'ai suivi le tuto http://viennet.developpez.com/cours/java/thread/
du coup dans le controller je fais :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
 
	    //j'extraie depuis un Thread pour que l'extraction se lance en asynchrone
	    ThreadZip tZip = new ThreadZip();
	    ThreadFichier tFichier = new ThreadFichier();
	    tZip.start();
	    while(tZip.getState().equals("RUNNABLE")) {
	        try
            {
                tFichier.wait();
            }
            catch (InterruptedException e)
            {
                e.printStackTrace();
            }
	    }
	    tFichier.start();
	}

j'ai tout essayé mais je sais pas quoi faire

je voudrais que tFichier attend jusqu'à que tZip ait fini

**adiGuba** · 25/01/2018, 12h34

Salut,

Mais... Pourquoi utiliser des threads si tu veux avoir des traitements séquentiels ?

a++

**Mr.Robot12** · 25/01/2018, 12h55

je peux faire sans l'utilisation des Threads ?
j'ai peut être oublié de dire que j'utilise les Threads pour que ces fonctions se lancent en asynchrone vu que je suis sur une appli web.

enfaite au début je voulais que l'extraction soit en arrière plan pour que la page n'attende pas la fin de l'extraction. du coup on m'a dit d'utiliser les Thread.

et donc je me suis dis que pour la lecture des fichiers extraites je dois utiliser un Thread aussi parce que si les fichiers ne sont pas extraites alors il n'y a pas encore de fichiers à lire. (pour le lancer en arrière plan aussi)

si c'est possible de faire sans les Thread je suis preneur vu que j'y connais rien dessus

**adiGuba** · 25/01/2018, 13h26

Envoyé par Mr.Robot12

j'ai peut être oublié de dire que j'utilise les Threads pour que ces fonctions se lancent en asynchrone vu que je suis sur une appli web.

En asynchrone avec quoi ?
Pas entre elle en tout cas, car sinon tu n'aurais pas à attendre la fin d'un thread pour démarrer l'autre (parce que çà c'est pas du tout de l'asynchrone).

Envoyé par Mr.Robot12

enfaite au début je voulais que l'extraction soit en arrière plan pour que la page n'attende pas la fin de l'extraction. du coup on m'a dit d'utiliser les Thread.

et donc je me suis dis que pour la lecture des fichiers extraites je dois utiliser un Thread aussi parce que si les fichiers ne sont pas extraites alors il n'y a pas encore de fichiers à lire. (pour le lancer en arrière plan aussi)

Dans ce cas utilise un thread pour TOUT le traitement, et non pas deux threads...

Envoyé par Mr.Robot12

si c'est possible de faire sans les Thread je suis preneur vu que j'y connais rien dessus

Qu'elle est l'objectif de tout cela exactement ?

PS : sinon n'oublies pas les try-with-ressource lorsque tu ouvres un fichier, pour éviter de laisser trainer des fichiers ouvert en cas d'erreur...

**Pill_S** · 25/01/2018, 13h31

Non non c'est pas ça le problème

tu utilises des threads et c'est très bien (encore que, en mode web/jee, c'est plutôt déconseillé), par contre, pourquoi vouloir attendre dans un thread qu'un autre ait fini?

C'est ça le non-sens, tu vérifie l'état d'un thread et tu l'exploite, mais tu n'attends pas qu'un thread soit fini pour continuer. Sinon ce n'est plus du multithread, c'est du mono-thread déguisé.

Ce que tu derais plutôt faire, c'est informer le consommateur que la tâche n'est pas encore terminée. Ton thread http-x va lire l'état du thread zip-1, et s'il n'a pas fini, remonte directement l'information "pas terminé" au consommateur.

PS: si vraiment tu veux le faire, tu peux, c'est la méthode ~~yield: Thread#yield~~ mais ce n'est pas conseillé

EDIT: c'est pas yield c'est join.... </fatigué>

**Mr.Robot12** · 25/01/2018, 14h10

Envoyé par adiGuba

Dans ce cas utilise un thread pour TOUT le traitement, et non pas deux threads...

c'est ce que je me disais aussi et j'ai essayé en mettant les 2 fonctions dans un seule thread et du coup c'est bon

ce que je voulais c'est que la page n'attende pas que ces 2 fonctions soit fini pour s'afficher

**Mr.Robot12** · 25/01/2018, 14h54

bon je vais mettre la discussion en résolue vu que mon problème est réglée.
merci à vous

**adiGuba** · 25/01/2018, 15h00

Oui mais que doit faire cette page ? Simplement lancer tout cela sans rien attendre en retour ?
Tu es conscient que si la page est appelée plusieurs fois cela va relancer plusieurs fois ce traitement.

=> Quel est l'objectif de cette page ?

**Mr.Robot12** · 25/01/2018, 15h06

Envoyé par adiGuba

Oui mais que doit faire cette page ? Simplement lancer tout cela sans rien attendre en retour ?
Tu es conscient que si la page est appelée plusieurs fois cela va relancer plusieurs fois ce traitement.

=> Quel est l'objectif de cette page ?

j'ai fais ça dans l'hypothèse où entre temps il y a une nouvelle archive etc....
parce que ces archives sont sur un serveur.

la page est une sorte de wiki en faite. les données des fichiers contiennent des données que je dois utiliser ensuite.

justement pour éviter que l'extraction se relance à chaque fois j'ai mis un contrôle qui vérifie si les archives sont déjà extraites ou pas. à terme je fais faire pareille je pense pour la lecture des fichiers.

si non je peux le mettre dans le init pour que ce soit lancé une seule fois aussi

**millie** · 31/01/2018, 17h08

Hum... Je n'arrive pas trop à comprendre.

Tu mets à disposition une servlet qui permet de dézipper une archive (qui est je ne sais où).
Et qu'advient-t'il de l'archive dézippé ?

Est-ce que tu pourrais remettre à plat ton besoin. L'utilisation de thread n'est à mon avis, non pertinente dans ton cas.

Et, il faut vraiment plus découper ton code.
Rien que pour la notion de "zip/dezip", il faut absolument créer une classe "ZipUtil" (ou "CompressUtil" etc.) avec une méthode du type :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
 
static public void unzip(File directory, File zipFile) throws IOException;

Elle peut-être testée unitairement tranquillement et n'a rien à faire au sein d'une classe aussi complexe.

**Mr.Robot12** · 31/01/2018, 19h22

si les archives n'ont pas été dézippé alors je les dézippe. j'ai mis un thread pour que l'extraction se fasse en arrière plan (pour que la page n'attende pas la fin de l'extraction pour s'afficher)
ensuite je lis chaque fichier dézippé. à terme je dois enregistrer les données que contiennent les fichiers dans une BDD.

j'ai mis un thread parce que c'est ce qu'on m'a dit de faire.

et la méthode unzip est bien dans une classe ZipFichier.
et la méthode qui lit les fichiers est dans une autre classe.

**Pill_S** · 01/02/2018, 11h25

Ce que millie voulait dire ('fin j'pense), c'est qu'il faut faire attention à découper correctement tes classes. Par exemple, un thread (toute classe étendant Thread) ne devrait pas faire grand chose à part appeler une (voir plusieurs) autre classe (qui elle n'étend pas thread) qui fait le boulot.

Le problème des threads, c'est qu'ils sont très difficiles à tester - et on sait que tout ce qui n'est pas testé, fini par merder

Isoler la complexité (dézipper est une tâche complexe!) dans une classe à part permet de la tester unitairement toute seule, isolée de tous les facteurs externes risquant d'influencer ou complexifier les tests. C'est pour ça qu'on parle de tests "unitaires".

PS: je rappelle que dans un environnement JEE (et même JEE-like), lancer soi-même des Threads est une mauvaise pratique. Il faut plutôt utiliser les API du container (par exemple, Worker, Executor, etc.), que l'on obtient via un lookup JNDI, qui lui s'occupera de fournir un thread managé, sorti d'un pool, que l'on pourra (le cas échéant) administrer via les outils du container (console d'admin et autres jmx)

**Mr.Robot12** · 01/02/2018, 11h29

Envoyé par Pill_S

Ce que millie voulait dire ('fin j'pense), c'est qu'il faut faire attention à découper correctement tes classes. Par exemple, un thread (toute classe étendant Thread) ne devrait pas faire grand chose à part appeler une (voir plusieurs) autre classe (qui elle n'étend pas thread) qui fait le boulot.

c'est ce que je fais en faite. la classe qui étend Thread ne fais que les appels aux méthodes qui eux sont dans des classes différentes.

Envoyé par Pill_S

PS: je rappelle que dans un environnement JEE (et même JEE-like), lancer soi-même des Threads est une mauvaise pratique. Il faut plutôt utiliser les API du container (par exemple, Worker, Executor, etc.), que l'on obtient via un lookup JNDI, qui lui s'occupera de fournir un thread managé, sorti d'un pool, que l'on pourra (le cas échéant) administrer via les outils du container (console d'admin et autres jmx)

pour utiliser les API que vous avez dit il faut un framework ? parce que je développe en JAVA sans framework.

**Pill_S** · 01/02/2018, 12h11

Oui, qui dépend de la plateforme sur laquelle vous développez (Tomcat, Websphere, Weblogic, JBoss, etc...)

**Mr.Robot12** · 01/02/2018, 12h12

je développe sur tomcat

**Pill_S** · 01/02/2018, 12h17

Alors ça, ça pourrait être utile: http://commonj.myfoo.de/install.shtml

**Mr.Robot12** · 01/02/2018, 12h18

je vais regarder ça merci

**tchize_** · 02/02/2018, 01h34

a noter qu'en J2EE (si tu peux ajouter les EJBs dans ton tomcat) il y a l'annotation @Asynchronous qui sert justement à faire exécuter une méthode en tâche de fond.

**Mr.Robot12** · 02/02/2018, 08h15

là où je fais mon stage j'ai pas les droits d'installer des appli ou en modifier du coup EJB je pourrai pas

**millie** · 02/02/2018, 16h29

Envoyé par Pill_S

Ce que millie voulait dire ('fin j'pense), c'est qu'il faut faire attention à découper correctement tes classes. Par exemple, un thread (toute classe étendant Thread) ne devrait pas faire grand chose à part appeler une (voir plusieurs) autre classe (qui elle n'étend pas thread) qui fait le boulot.

Oui, je voulais effectivement dire ça

Faire attendre un Thread jusqu'à la fin d'un autre

Concurrence et multi-thread Java

Discussions similaires

Partager

Partager