Semaphore實現的生產者消費者程序

Semaphore：Semaphores are often used to restrict the number of threads than can access some (physical or logical) resource.

import java.util.LinkedList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.Semaphore;

class Buffer {

    List<Integer> buffer = new LinkedList<Integer>();
    // 互斥量，控制buffer的互斥訪問
    private Semaphore mutex = new Semaphore(1);

    // canProduceCount可以生產的數量（表示緩沖區可用的數量）。 通過生產者調用acquire，減少permit數目
    private Semaphore canProduceCount = new Semaphore(10);

    // canConsumerCount可以消費的數量。通過生產者調用release，增加permit數目
    private Semaphore canConsumerCount = new Semaphore(0);
    Random rn = new Random(10);

    public void get() throws InterruptedException {
        canConsumerCount.acquire();
        try {
            mutex.acquire();
            int val = buffer.remove(0);
            System.out
                    .println(Thread.currentThread().getName() + " 正在消費數據為：" + val + "    buffer目前大小為：" + buffer.size());
        } finally {
            mutex.release();
            canProduceCount.release();
        }

    }

    public void put() throws InterruptedException {
        canProduceCount.acquire();
        try {
            mutex.acquire();
            int val = rn.nextInt(10);
            buffer.add(val);
            System.out
                    .println(Thread.currentThread().getName() + " 正在生產數據為：" + val + "    buffer目前大小為：" + buffer.size());
        } finally {
            mutex.release();
            // 生產者調用release，增加可以消費的數量
            canConsumerCount.release();
        }

    }
}

public class SemaphoreProducerComsumer1 {

    public static void main(String[] args) {
        final Buffer buffer = new Buffer();
        startProducer(buffer);
        startProducer(buffer);
        startConsumer(buffer);
        startConsumer(buffer);

    }

    public static void startProducer(final Buffer buffer) {
        new Thread(new Runnable() {

            @Override
            public void run() {
                try {
                    while (true) {
                        buffer.put();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }
        }).start();
    }

    public static void startConsumer(final Buffer buffer) {
        new Thread(new Runnable() {

            @Override
            public void run() {
                try {
                    while (true) {
                        buffer.get();
                    }
                } catch (Exception e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }

            }
        }).start();
    }

}