import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;

/**
 * Created by wisgood .
 */
public class ProducerConsumerWithBlockingQueueDemo {
    public static void main(String[] args) {
        BlockingQueue<String> productFactory = new ArrayBlockingQueue(10);
        new
 
 Thread(new ProducerWithBlockingQueue(productFactory), "1號生產者").start();
        new Thread(new ConsumerWithBlockingQueue(productFactory), "1號消費者").start();
        new Thread(new ConsumerWithBlockingQueue(productFactory), "2號消費者").start();
    }
}


// 生產者
class ProducerWithBlockingQueue implements Runnable {
    private
 
  BlockingQueue<String> productFactory;
    public ProducerWithBlockingQueue( BlockingQueue<String> productFactory) {
        this.productFactory = productFactory;
    }
    public void run() {
        int i = 0;
        while (true) {
            try {
                String product = String.valueOf(i) ;
                //只有下面1行程式碼會互斥訪問productFactory
 

                productFactory.put(product);
                System.out.println("執行緒(" + Thread.currentThread().getName() + ")生產了一件產品:" + product + ";當前剩餘商品" + productFactory.size() + "個");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            i++;
        }
    }
}

// 消費者
class ConsumerWithBlockingQueue implements Runnable {
    private  BlockingQueue<String> productFactory;
    public ConsumerWithBlockingQueue(BlockingQueue<String> productFactory) {
        this.productFactory = productFactory;
    }

    public void run() {
        while (true) {
            try {
                System.out.println("執行緒(" + Thread.currentThread().getName() + ")消費了一件產品:" + productFactory.take() + ";當前剩餘商品" + productFactory.size() + "個");
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }
}

輸出結果

執行緒(1號消費者)消費了一件產品:0;當前剩餘商品0個
執行緒(1號生產者)生產了一件產品:1;當前剩餘商品1個
執行緒(2號消費者)消費了一件產品:1;當前剩餘商品0個
執行緒(1號生產者)生產了一件產品:2;當前剩餘商品1個
執行緒(1號消費者)消費了一件產品:2;當前剩餘商品0個
執行緒(1號生產者)生產了一件產品:3;當前剩餘商品1個
執行緒(2號消費者)消費了一件產品:3;當前剩餘商品0個
執行緒(1號生產者)生產了一件產品:4;當前剩餘商品1個
執行緒(1號消費者)消費了一件產品:4;當前剩餘商品0個
執行緒(1號生產者)生產了一件產品:5;當前剩餘商品1個
執行緒(2號消費者)消費了一件產品:5;當前剩餘商品0個
執行緒(1號生產者)生產了一件產品:6;當前剩餘商品1個
執行緒(1號消費者)消費了一件產品:6;當前剩餘商品0個

文章為作者原創文章，如果對您有幫助，歡迎打賞！