Java : Exemple de consommateur de producteur - Gérer la lecture/écriture simultanée

Publié: 2019-02-17

Exemple Producteur Consommateur - Gérer la lecture simultanée : écriture

Le producer-consumer problem (également connu sous le nom bounded-buffer problem ) est un exemple Java classique d'un problème de synchronisation multi-processus.

Le problème décrit deux processus, the producer et the consumer , qui partagent un tampon commun de taille fixe utilisé comme file d'attente. Le travail du producteur est de générer une donnée, de la mettre dans la mémoire tampon et de recommencer.

Dans le même temps, le consommateur consomme les données (c'est-à-dire les supprime de la mémoire tampon) une pièce à la fois. Le problème est de s'assurer que le producteur n'essaiera pas d'ajouter des données dans le tampon s'il est plein et que le consommateur n'essaiera pas de supprimer des données d'un tampon vide.

Le programme Java ci-dessous créera ce problème :

Exemples Java - Problème producteur-consommateur

CrunchifyProducerConsumer.java
Java
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
package com . crunchify . tutorials ;
 
import java . util . Vector ;
import java . util . Iterator ;
 
/**
* @author Crunchify
*/
 
public class CrunchifyProducerConsumer {
     private static Vector <Object> data = new Vector <Object> ( ) ;
 
     public static void main ( String [ ] args ) {
         new Producer ( ) . start ( ) ;
         new Consumer ( ) . start ( ) ;
     }
 
     public static class Consumer extends Thread {
         Consumer ( ) {
             super ( "Consumer" ) ;
         }
 
         @Override
         public void run ( ) {
             for ( ; ; ) {
                 try {
                     Thread . sleep ( 1 ) ;
                 } catch ( Exception e ) {
                     e . printStackTrace ( ) ;
                 }
                 @SuppressWarnings ( "rawtypes" )
                 Iterator it = data . iterator ( ) ;
                 while ( it . hasNext ( ) )
                     it . next ( ) ;
             }
         }
     }
 
     public static class Producer extends Thread {
         Producer ( ) {
             super ( "Producer" ) ;
         }
 
         @Override
         public void run ( ) {
             for ( ; ; ) {
                 try {
                     Thread . sleep ( 1 ) ;
                 } catch ( Exception e ) {
                     e . printStackTrace ( ) ;
                 }
                 data . add ( new Object ( ) ) ;
                 if ( data . size ( ) > 1000 )
                     data . remove ( data . size ( ) - 1 ) ;
             }
         }
     }
}

Publier:

ConcurrentModificationException
1
2
3
4
Exception in thread "Consumer" java . util . ConcurrentModificationException
     at java . util . ArrayList $ Itr . checkForComodification ( ArrayList . java : 819 )
     at java . util . ArrayList $ Itr . next ( ArrayList . java : 791 )
     at com . crunchify . tutorials . CrunchifyProducerConsumer $ Consumer . run ( CrunchifyProducerConsumer . java : 36 )

Résolution:

Ajoutez le mot clé synchronized pour verrouiller les data pendant que nous les utilisons.

Meilleur programme Java :

CrunchifyProducerConsumer.java
Java
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
61
62
63
64
package crunchify . com . tutorials ;
 
import java . util . Iterator ;
import java . util . Vector ;
 
/**
* @author Crunchify.com
* Producer Consumer Example in Java
*/
 
public class CrunchifyProducerConsumer {
private static Vector <Object> data = new Vector <Object> ( ) ;
 
public static void main ( String [ ] args ) {
new Producer ( ) . start ( ) ;
new Consumer ( ) . start ( ) ;
}
 
public static class Consumer extends Thread {
Consumer ( ) {
super ( "Consumer" ) ;
}
 
@SuppressWarnings ( "rawtypes" )
@Override
public void run ( ) {
for ( ; ; ) {
try {
Thread . sleep ( 1000 ) ;
System . out . println ( "Object Consumed ################" ) ;
} catch ( Exception e ) {
e . printStackTrace ( ) ;
}
 
synchronized ( data ) {
Iterator it = data . iterator ( ) ;
while ( it . hasNext ( ) )
it . next ( ) ;
}
}
}
}
 
public static class Producer extends Thread {
Producer ( ) {
super ( "Producer" ) ;
}
 
@Override
public void run ( ) {
for ( ; ; ) {
try {
Thread . sleep ( 1000 ) ;
System . out . println ( "Object Produced ~~~~~~~~~~~~~~~" ) ;
} catch ( Exception e ) {
e . printStackTrace ( ) ;
}
data . add ( new Object ( ) ) ;
if ( data . size ( ) > 1000 )
data . remove ( data . size ( ) - 1 ) ;
}
}
}
}

Résultat de l'exemple de consommateur de producteur Java :

java-producteur-consommateur-tutoriel-crunchify