[Langage] Declaration d'une FIFO de tableaux d'int thread safe java (comportement etrange)

**gazawik13** · 04/12/2014, 11h42

bonjour,

En java, J'essaye d'utiliser une FIFO (queue) dont chaque "element" est un tableau d'int. Cette fifo devant etre écrite / lue par deux threads differents, je me suis tourné vers une ConcurrentLinkedQueue . Tout va bien tant que je déclare des elements simples type "Integer" ou "String", mais je ne comprends plus le fonctionnement quand je veux déclarer des tableaux de int ( int[] ) pour chaque element. La FIFO me renvoit "comme le dernier élément, je dois me gaufrer dans la récupération (poll), comme si le "pointeur" du tableau de la fifo lue n'etait pas bien interpreté..

je vous met un exemple de code simple que j'ai dérivé d'un example :

il consiste juste à déclarer un tableau de int, dont je vais modifier le 2ème element à chaque écrite dans la queue fifo. J'écris la fifo rapidement et je la lis lentement. on voit que le nombre d'elements est correct (le poll vide bien la fifo) mais le contenu rapatrié par poll semble erroné (le 2eme element du tableau rappatrié par poll ne contient pas le bon numero, il contient systematiquement le dernier element écrit et plusieurs fois de suite (ce n'est pas non plus une pile!):

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
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
49
50
51
52
53
54
55
56
57
58
59
60
 
import java.util.concurrent.*;
 
public class ConcurrentLinkedQueueExample {
   public static void main(String[] args) {
      ConcurrentLinkedQueue<int[]> queue = new ConcurrentLinkedQueue<int[]>();
      Thread producer = new Thread(new Producer(queue));
      Thread consumer = new Thread(new Consumer(queue));
      producer.start();
      consumer.start();
  }
}
 
// the producer puts strings on the queue 
class Producer implements Runnable {
  private int[] ligneecrite;
   ConcurrentLinkedQueue<int[]> queue;
   Producer(ConcurrentLinkedQueue<int[]> queue){
      this.queue = queue;
   }
   public void run() {
	  ligneecrite=new int [10];
      System.out.println("Producer Started");
      try {
         for (int i = 1; i < 20; i++) {
        	 ligneecrite[0] = 0;
        	 ligneecrite[1] = i;
        	 ligneecrite[2] = 0;
            queue.add(ligneecrite);
            System.out.println("++ > Added: id contenu dans le 2eme element " + ligneecrite[1]);
            Thread.currentThread().sleep(200);
         }
      } catch (Exception ex) {
         ex.printStackTrace();
      }
   }
}
 
// the consumer removes strings from the queue
class Consumer implements Runnable {
	int[] lignelue;
   ConcurrentLinkedQueue<int[]> queue;
   Consumer(ConcurrentLinkedQueue<int[]> queue){
      this.queue = queue;
   }
   public void run() {
      String str;
      System.out.println("Consumer Started");
      for (int x = 0; x < 20; x++) {
         while ((lignelue = queue.poll()) != null) {
            System.out.println("---- > Removed: id contenu dans le 2eme element " + lignelue[1]);
         }
         try {
            Thread.currentThread().sleep(500);
         } catch (Exception ex) {
            ex.printStackTrace();
         }
      }
   }
}

cela donne :

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
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
Producer Started
Consumer Started
++ > Added: id contenu dans le 2eme element 1
---- > Removed: id contenu dans le 2eme element 1
++ > Added: id contenu dans le 2eme element 2
++ > Added: id contenu dans le 2eme element 3
---- > Removed: id contenu dans le 2eme element 3
---- > Removed: id contenu dans le 2eme element 3
++ > Added: id contenu dans le 2eme element 4
++ > Added: id contenu dans le 2eme element 5
---- > Removed: id contenu dans le 2eme element 5
---- > Removed: id contenu dans le 2eme element 5
++ > Added: id contenu dans le 2eme element 6
---- > Removed: id contenu dans le 2eme element 6
++ > Added: id contenu dans le 2eme element 7
++ > Added: id contenu dans le 2eme element 8
---- > Removed: id contenu dans le 2eme element 8
---- > Removed: id contenu dans le 2eme element 8
++ > Added: id contenu dans le 2eme element 9
++ > Added: id contenu dans le 2eme element 10
---- > Removed: id contenu dans le 2eme element 10
---- > Removed: id contenu dans le 2eme element 10
++ > Added: id contenu dans le 2eme element 11
++ > Added: id contenu dans le 2eme element 12
++ > Added: id contenu dans le 2eme element 13
---- > Removed: id contenu dans le 2eme element 13
---- > Removed: id contenu dans le 2eme element 13
---- > Removed: id contenu dans le 2eme element 13
++ > Added: id contenu dans le 2eme element 14
++ > Added: id contenu dans le 2eme element 15
---- > Removed: id contenu dans le 2eme element 15
---- > Removed: id contenu dans le 2eme element 15
++ > Added: id contenu dans le 2eme element 16
++ > Added: id contenu dans le 2eme element 17
++ > Added: id contenu dans le 2eme element 18
---- > Removed: id contenu dans le 2eme element 18
---- > Removed: id contenu dans le 2eme element 18
---- > Removed: id contenu dans le 2eme element 18
++ > Added: id contenu dans le 2eme element 19
---- > Removed: id contenu dans le 2eme element 19

> Fonctionnement identique avec Java 1.6 et Java 1.7.

je sèche un peu.... auriez vous une piste ? une autre façon de faire cette fifo de tableaux de int thread safe ?

merci

Merci de votre aide;;

**thelvin** · 04/12/2014, 12h15

Mais... il n'y a qu'un seul tableau int[] dans ton code. Tu ne fais qu'un seul new...

**Alkhan** · 05/12/2014, 08h18

bonjour,

je suis entièrement d'accord avec ce que tu as dis @thelvin, mais je pense qu'une précision s'impose pour que les débutants comprennent !

Le fait de faire un "queue.add(ligneecrite);" fait bien que la FIFO contiendra bien n éléments.
Cependant du fait que le tableau est créé a l’extérieur de la boucle la FIFO contiendra n fois la référence du même tableau, donc à la fin de la boucle tout les nœuds de la FIFO auront les même valeur puisque qu'il n'y a en réalité qu'un seul tableau.
Il faut donc, pour que cela fonctionne, mettre la création du tableau dans la boucle et c'est seulement a cette condition que tu aura n tableau différent.

**gazawik13** · 05/12/2014, 09h38

merci,si j'ai bien compris, il a suffit de remplacer

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
public void run() {
	  ligneecrite=new int [10];
      System.out.println("Producer Started");
      try {
         for (int i = 1; i < 20; i++) {
        	 ligneecrite[0] = 0;
        	 ligneecrite[1] = i;
        	 ligneecrite[2] = 0;
            queue.add(ligneecrite);
            System.out.println("++ > Added: id contenu dans le 2eme element " + ligneecrite[1]);
            Thread.currentThread().sleep(200);
         }
      } catch (Exception ex) {
         ex.printStackTrace();
      }

par

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
   public void run() {
      System.out.println("Producer Started");
      try {
         for (int i = 1; i < 20; i++) {
        	 ligneecrite=new int [10];
        	 ligneecrite[0] = 0;
        	 ligneecrite[1] = i;
        	 ligneecrite[2] = 0;
            queue.add(ligneecrite);
            System.out.println("++ > Added: id contenu dans le 2eme element " + ligneecrite[1]);
            Thread.currentThread().sleep(200);
         }
      } catch (Exception ex) {
         ex.printStackTrace();
      }

merci ! (ça marche!)

du coup, est ce que la mémoire est correctement gérée ensuite, à mesure que je fais les poll ? Est ce qu'il faut faire quelque chose de particulier pour liberer les espaces mémoires créés par le NEW ?

**Logan Mauzaize** · 05/12/2014, 10h01

Java garde en mémoire les objets tant qu'ils sont référencés. Et les libère ensuite selon son "bon vouloir" (au bout d'un certains temps ou quand la mémoire vient à manquer).

Dans ton cas, il est d'abord référencé par le producteur dans la boucle puis passer dans la file. Cependant le producteur garde la référence du dernier élément (utilisation d'un attribut).
Puis le consommateur retire la référence de la file et la stocke également dans un attribut. Le consommateur garde donc également la référence du dernier élément.

Enfin le programme s'arrête et tout est libéré

Tu devrais "déplacer" ton attribut en tant que variable locale (dans la boucle pour le producteur, juste avant pour le consommateur).

[Langage] Declaration d'une FIFO de tableaux d'int thread safe java (comportement etrange)

Concurrence et multi-thread Java

Discussions similaires

Partager

Partager