Java: Producer Consumer Esempio – Gestisci lettura/scrittura simultanea

Pubblicato: 2019-02-17

Esempio produttore consumatore - Gestisci lettura: scrittura simultanea

Il producer-consumer problem (noto anche come bounded-buffer problem ) è un classico esempio Java di un problema di sincronizzazione multiprocesso.

Il problema descrive due processi, the producer e the consumer , che condividono un buffer comune a dimensione fissa utilizzato come coda. Il compito del produttore è generare un dato, inserirlo nel buffer e ricominciare.

Allo stesso tempo, il consumatore sta consumando i dati (cioè rimuovendoli dal buffer) un pezzo alla volta. Il problema è assicurarsi che il produttore non tenti di aggiungere dati nel buffer se è pieno e che il consumatore non tenti di rimuovere i dati da un buffer vuoto.

Di seguito un semplice programma Java creerà questo problema:

Esempi Java – Problema del consumatore del produttore

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 ) ;
             }
         }
     }
}

Problema:

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 )

Risoluzione:

Aggiungi la parola chiave synchronized per bloccare i data mentre li stiamo utilizzando.

Programma Java migliore:

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 ) ;
}
}
}
}

Risultato dell'esempio di consumo del produttore Java:

java-producer-consumer-tutorial-crunchify