1. public class ProduceConsumerDemo3 {
   
2.     public static void main(String[] args) {
   
3.             //创建一个容量为1的队列
   
4.             BlockingQueue<String> bq=new ArrayBlockingQueue<String>(1);
   
5.             //启动三个生产者
   
6.             new Thread(new Producer1(bq)).start();
   
7.             new Thread(new Producer1(bq)).start();
   
8.             new Thread(new Producer1(bq)).start();
   
9.            
   
10.             //启动一个消费者
    
11.             new Thread(new Consumer1(bq)).start();
    
12.         }
    
13. }
    
14. class Producer1 implements Runnable
    
15. {
    
16.         private BlockingQueue<String> bq;
    
17.         public Producer1(BlockingQueue<String> bq)
    
18.         {
    
19.                 this.bq=bq;
    
20.         }
    
21.         @Override
    
22.         public void run() {
    
23.                 String []strArr=new String[]{"java","struts","Spring"};
    
24.                 for (int i = 0; i < 99999; i++)
    
25.                 {
    
26.                         System.out.println(Thread.currentThread().getName()+"----生产者----");
    
27.                         try {
    
28.                                 bq.put(strArr[i%3]);
    
29.                         } catch (Exception e) {
    
30.                                 // TODO: handle exception
    
31.                         }
    
32.                 }
    
33.         }
    
34. }
    
35. class Consumer1 implements Runnable
    
36. {
    
37.         private BlockingQueue<String> bq;
    
38.         public Consumer1(BlockingQueue<String> bd)
    
39.         {
    
40.                 this.bq=bq;
    
41.         }
    
42.         @Override
    
43.         public void run() {
    
44.                 while (true) {
    
45.                        
    
46.                         try {
    
47.                                 System.out.println(Thread.currentThread().getName()+"---消费者--"+bq.take());
    
48.                         } catch (Exception e) {
    
49.                                 // TODO: handle exception
    
50.                         }
    
51.                
    
52.                 }
    
53.         }
    

复制代码

运行的时候，程序好像挂起啦，CPU一下子达到90%啦，谁能帮我分析下

不好意思，打扰各位啦，问题已经解决啦，我参数写错啦哎，太粗心啦，