だから私はJavaのスレッド同期についてかなり読んだ。現在、バウンドバッファの問題を試しています。消費者がそれを消費し続けている間、生産者はバッファで製品を生産し続けます。
生産者は、バッファがいっぱいになると、別の製品を生産する前に待機します。バッファが空の場合、コンシューマは待機します。
ただし、私の問題は、バッファーがいっぱいになるまで、バッファーが空のときにのみ生産を開始することです。コンシューマーは、バッファーが空になるまで、バッファーがいっぱいになったときにのみ消費を開始します。
例（バッファサイズ：5）
Produced Product 1
Produced Product 2
Produced Product 3
Produced Product 4
Produced Product 5
Consumed Product 1
Consumed Product 2
Consumed Product 3
Consumed Product 4
Consumed Product 5
Produced Product 6
Produced Product 7
Produced Product 8
Produced Product 9
Produced Product 10
Consumed Product 6
Consumed Product 7
Consumed Product 8
Consumed Product 9
Consumed Product 10
Produced Product 11
Produced Product 12
Produced Product 13
Produced Product 14
Produced Product 15
Consumed Product 11
Consumed Product 12
Consumed Product 13
Consumed Product 14
Consumed Product 15
Produced Product 16
Produced Product 17
Produced Product 18
Produced Product 19
Produced Product 20
Consumed Product 16
Consumed Product 17
Consumed Product 18
Consumed Product 19
Consumed Product 20
Produced Product 21
Produced Product 22
Produced Product 23
Produced Product 24
Produced Product 25
Consumed Product 21
Consumed Product 22
Consumed Product 23
Consumed Product 24
Consumed Product 25
Produced Product 26
Produced Product 27
Produced Product 28
Produced Product 29
Produced Product 30
Consumed Product 26
Consumed Product 27
Consumed Product 28
Consumed Product 29
Consumed Product 30
バッファーが空であるかどうかに関係なく、バッファーがいっぱいでない限り、プロデューサーが生成するようにします。その後、バッファがいっぱいかどうかに関係なく、バッファが空でない限り消費者が消費するようにしたい。
コードの何が問題になっていますか?
import java.util.LinkedList;
import java.util.Queue;
import java.util.Random;
import javax.swing.JOptionPane;
public class ProducerConsumer{
final static Queue<Product> buffer = new LinkedList<>();
private static int buffer_size, no_items, itemno = 1;
private static Random r = new Random();
public static void main(String[] args) {
try{
buffer_size = Integer.parseInt(JOptionPane.showInputDialog("Input Buffer size (default: 5)"));
if(buffer_size<0){
buffer_size = 5;
}
}catch(NumberFormatException nfe){
buffer_size = 5;
}
try{
no_items = Integer.parseInt(JOptionPane.showInputDialog("Input No. of Items (default: 10)"));
if(no_items<0){
no_items = 10;
}
}catch(NumberFormatException nfe){
no_items = 10;
}
Producer producer = new Producer();
Consumer consumer = new Consumer();
producer.start();
consumer.start();
}
static class Product {
private String name = "Product X";
private int productno;
public Product(int productno) {
this.productno = productno;
this.name = "Product "+productno;
}
public int number() {
return productno;
}
@Override
public String toString() {
return name;
}
}
static class Producer extends Thread{
public Producer(){
}
public void produce(){
Product p = new Product(itemno++);
try {
this.sleep(r.nextInt(100));
} catch (InterruptedException ex) {
Thread.interrupted();
}
buffer.add(p);
System.out.println("Produced "+p);
}
@Override
public void run(){
synchronized(buffer){
while(itemno<=no_items){
while(buffer.size()==buffer_size){
try{
buffer.wait(100);
}catch(InterruptedException e){
Thread.interrupted();
}
}
produce();
buffer.notifyAll();
}
}
}
}
static class Consumer extends Thread{
public Consumer(){
}
public boolean consume(){
try {
this.sleep(r.nextInt(100));
} catch (InterruptedException ex) {
Thread.interrupted();
}
Product product = buffer.remove();
System.out.println("Consumed "+product);
return product.number()==no_items;
}
@Override
public void run(){
synchronized(buffer){
boolean end = false;
while(!end){
while(buffer.isEmpty()){
try{
buffer.wait(100);
}catch(InterruptedException e){
Thread.interrupted();
}
}
end = consume();
buffer.notifyAll();
}
}
}
}
}