2

我有一个标准的生产者消费者问题。生产者将数据放入堆栈（缓冲区）消费者接受它。

我希望有很多生产者和消费者。

问题是我只想让最后一个活着的制作人能够打电话b.stop()

for(int i = 0; i < 10; i++){
        try{
    //      sleep((int)(Math.random() * 1));                
        }catch(Exception e){e.printStackTrace();}
        b.put((int) (Math.random()* 10));
        System.out.println("i = " + i);
    }
    b.stop();

那么我将b.stop()which changes runningfield in称为Bufferfalse 和notifiesAll()

结束然后我得到：

i = 9 // number of iteration this is 10th iteration
Consumer 2.: no data to take. I wait.  Memory: 0
Consumer 1.: no data to take. I wait.  Memory: 0
Consumer 3.: no data to take. I wait.  Memory: 0

他们应该死了，所以我做了方法 stop() 但它没有用。

代码正在运行，请检查

import java.util.Stack;


public class Buffer {
private static int SIZE = 4;
private int i;//number of elements in buffer
public Stack<Integer> stack;
private volatile boolean running;
    public Buffer() {
        stack = new Stack<>();
        running = true;
        i = 0;
    }
    synchronized public void put(int val){
        while (i >= SIZE) {
            try {
                System.out.println("Buffer full, producer waits");
                wait();
            } catch (InterruptedException exc) {
                exc.printStackTrace();
            }
        }   
        stack.push(val);//txt = s;
        i++;
        System.out.println("Producer inserted " + val + " memory: " + i);
        if(i - 1 == 0)
            notifyAll();
        System.out.println(stack);
    }

    public synchronized Integer get(Consumer c) {
        while (i == 0) {
            try {
                System.out.println(c + ": no data to take. I wait.  Memory: " + i);
                wait();
            } catch (InterruptedException exc) {
                exc.printStackTrace();
            }
        }   
        if(running){
            int data = stack.pop();
            i--;    
            System.out.println(c+  ": I took: " + data +" memory: " +  i);
            System.out.println(stack);
            if(i + 1 == SIZE){//if the buffer was full so the producer is waiting
                notifyAll();
                System.out.println(c +  "I notified producer about it");
        }
        return data;}
        else 
            return null;
    }

    public boolean isEmpty(){
        return i == 0;
    }
    public synchronized void stop(){//I THOUGH THIS WOULD FIX IT~!!!!!!!!!!!!!!
        running = false;
        notifyAll();
    }
    public boolean isRunning(){
        return running;
    }

}

public class Producer extends Thread {
private Buffer b;
    public Producer(Buffer b) {
        this.b = b;
    }

    public void run(){
        for(int i = 0; i < 10; i++){
            try{
        //      sleep((int)(Math.random() * 1));                
            }catch(Exception e){e.printStackTrace();}
            b.put((int) (Math.random()* 10));
            System.out.println("i = " + i);
        }
        b.stop();
    }

}

public class Consumer extends Thread {
    Buffer b;
    int nr;
    static int NR = 0;

    public Consumer(Buffer b) {
        this.b = b;
        nr = ++NR;
    }

    public void run() {
        Integer i = b.get(this);
        while (i != null) {
            System.out.println(nr + " I received : " + i);
            i = b.get(this);
        }
        System.out.println("Consumer " + nr + " is dead");
    }

    public String toString() {
        return "Consumer " + nr + ".";
}

}

public class Main {

    public static void main(String[] args) {

        Buffer b = new Buffer();
        Producer p = new Producer(b);
        Consumer c1 = new Consumer(b);
        Consumer c2 = new Consumer(b);
        Consumer c3 = new Consumer(b);  
        p.start();
        c1.start();c2.start();c3.start();

    }

}
4

4 回答 4

1

您必须意识到您的线程可能在以下两个位置中的任何一个中等待：

  1. 在wait循环中i == 0- 在这种情况下notifyall会将所有这些都踢出去。但是，如果i仍然如此0，他们将直接再次等待。
  2. 等待对对象的独占访问（即等待synchronized方法）-在这种情况下（如果您修复了上面的问题 1 并且锁将被释放），它们将直接进入while (i == 0)循环。

我建议您将while ( i == 0 )循环更改为while ( running && i == 0 ). 这应该可以解决您的问题。由于您的running标志（正确）volatile所有都应该整齐地退出。

于 2013-04-20T23:13:29.453 回答
0

作为对只有最后一个活着的生产者能够调用 b.stop() 的回答。

您应该在包含生产者数量的情况下添加一个AtomicInteger，Buffer并在其构造函数中进行每个生产者调用b.start()（增加它）。

这样你就可以减少它，b.stop()只有当它变为零时才应该running设置为false.

于 2013-04-21T16:48:28.150 回答
0

我会重新考虑你的设计。类应该有一套连贯的职责；让一个类负责从队列中消费对象，同时还负责关闭其他消费者，这似乎是您想要分开的事情。

于 2013-04-21T11:51:05.863 回答
0

在您的stop方法中，您设置running为false，但您的 while 循环运行时间为i == 0。设置i为不同于零的值，它应该修复它。

顺便说一句，我不明白为什么你有一个running变量和一个单独的i变量，这实际上是保持线程运行的变量。

于 2013-04-20T22:38:43.017 回答