语源科技BlogJava-一磕一碰http://www.blogjava.net/dericgit/js/javazh-cnWed, 06 May 2026 23:11:10 GMTWed, 06 May 2026 23:11:10 GMT60通过wait和notify实现的生产者消费者demohttp://www.blogjava.net/dericgit/archive/2012/12/04/392394.html一磕一碰一磕一碰Tue, 04 Dec 2012 02:06:00 GMThttp://www.blogjava.net/dericgit/archive/2012/12/04/392394.htmlhttp://www.blogjava.net/dericgit/comments/392394.htmlhttp://www.blogjava.net/dericgit/archive/2012/12/04/392394.html#Feedback0http://www.blogjava.net/dericgit/comments/commentRss/392394.htmlhttp://www.blogjava.net/dericgit/services/trackbacks/392394.htmlJava代码  :
import java.util.ArrayList;  
import java.util.List;  
/** 
 * 通过wait和notify实现的生产者消费者demo 
 * User: zhangb 
 * Date: 12-12-1 
 * Time: 下午7:19 
 */  
public class ProducerAndCustomerDemo {  
    private static int capacity = 150;  
    private static List<String> basket = new ArrayList<String>(capacity);  
  
    public static void main(String[] args) {  
        // 多生产者与多消费者  
        int producerSize = 2;  
        Thread[] ps = new Thread[producerSize];  
        for (int i = 0, step = 500; i < producerSize; i ++) {  
            ps[i] = new Thread(new Producer((i) * step, (i+1) * step), "生产-->线程--" + (i+1));  
            ps[i].start();  
        }  
  
        int customerSize = 10;  
        Thread[] cs = new Thread[customerSize];  
        for (int i = 0; i < customerSize; i ++) {  
            cs[i] = new Thread(new Customer(), "消费线程--" + (i+1));  
            cs[i].start();  
        }  
  
        // 等待生产线程结束并中断消费线程  
        for (int i = 0; i < producerSize; i ++) {  
            try {  
                ps[i].join();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
        }  
        for (int i = 0; i < customerSize; i ++) {  
            cs[i].interrupt();  
        }  
    }  
    static class Producer implements Runnable {  
        private int start;  
        private int end;  
  
        Producer(int start, int end) {  
            this.start = start;  
            this.end = end;  
        }  
  
        @Override  
        public void run() {  
            for (int i = start; i < end; i ++) {  
                synchronized (basket) {  
                    try {  
                        while (basket.size() == capacity) {  
                            basket.wait();  
                        }  
                        String p = " PRO" + i;  
                        System.out.println(Thread.currentThread().getName() + p);  
                        basket.add(p);  
                        basket.notifyAll();  
                        Thread.yield(); // 让出当前线程的执行权,有利于看出交替线程运行的效果  
                    } catch (InterruptedException e) {  
                        e.printStackTrace();  
                        break;  
                    }  
                }  
            }  
        }  
    }  
    static class Customer implements Runnable {  
        @Override  
        public void run() {  
            while (true) {  
                synchronized (basket) {  
                    try{  
                        while (basket.size() == 0) {  
                            basket.wait();  
                        }  
                        System.out.println(Thread.currentThread().getName() + basket.remove(0));  
                        basket.notifyAll();  
                    } catch (InterruptedException e) {  
                        System.out.println(Thread.currentThread().getName() + "退出");  
                        break;  
                    }  
                }  
            }  
        }  
    }  
}  


一磕一碰 2012-12-04 10:06 发表评论
]]>