BlockingQueue小谈

痛定思痛。 2022-06-15 09:10 265阅读 0赞

方法：

<table> 
 <tbody> 
  <tr> 
   <td><code>boolean</code></td> 
   <td><code><span><a rel="nofollow">add</a></span>(<a title="type parameter in BlockingQueue" rel="nofollow">E</a>&nbsp;e)</code> 
    <div>
      将指定的元素插入到此队列中，如果可以立即执行此操作而不违反容量限制， 
     <code>true</code>在成功后返回 
     <code> IllegalStateException</code>如果当前没有可用空间，则抛出IllegalStateException。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>boolean</code></td> 
   <td><code><span><a rel="nofollow">contains</a></span>(<a title="class in java.lang" rel="nofollow">Object</a>&nbsp;o)</code> 
    <div>
      如果此队列包含指定的元素，则返回 
     <code>true</code> 。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>int</code></td> 
   <td><code><span><a rel="nofollow">drainTo</a></span>(<a title="interface in java.util" rel="nofollow">Collection</a>&lt;? super <a title="type parameter in BlockingQueue" rel="nofollow"> E</a>&gt;&nbsp;c)</code> 
    <div>
      从该队列中删除所有可用的元素，并将它们添加到给定的集合中。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>int</code></td> 
   <td><code><span><a rel="nofollow">drainTo</a></span>(<a title="interface in java.util" rel="nofollow">Collection</a>&lt;? super <a title="type parameter in BlockingQueue" rel="nofollow"> E</a>&gt;&nbsp;c, int&nbsp;maxElements)</code> 
    <div>
      最多从该队列中删除给定数量的可用元素，并将它们添加到给定的集合中。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>boolean</code></td> 
   <td><code><span><a rel="nofollow">offer</a></span>(<a title="type parameter in BlockingQueue" rel="nofollow">E</a>&nbsp;e)</code> 
    <div>
      将指定的元素插入到此队列中，如果可以立即执行此操作，而不会违反容量限制， 
     <code>true</code>在成功时 
     <code> false</code>如果当前没有可用空间，则返回false。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>boolean</code></td> 
   <td><code><span><a rel="nofollow">offer</a></span>(<a title="type parameter in BlockingQueue" rel="nofollow">E</a>&nbsp;e, long&nbsp;timeout, <a title="enum in java.util.concurrent" rel="nofollow"> TimeUnit</a>&nbsp;unit)</code> 
    <div>
      将指定的元素插入到此队列中，等待指定的等待时间（如有必要）才能使空间变得可用。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code><a title="type parameter in BlockingQueue" rel="nofollow">E</a></code></td> 
   <td><code><span><a rel="nofollow">poll</a></span>(long&nbsp;timeout, <a title="enum in java.util.concurrent" rel="nofollow"> TimeUnit</a>&nbsp;unit)</code> 
    <div>
      检索并删除此队列的头，等待指定的等待时间（如有必要）使元素变为可用。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>void</code></td> 
   <td><code><span><a rel="nofollow">put</a></span>(<a title="type parameter in BlockingQueue" rel="nofollow">E</a>&nbsp;e)</code> 
    <div>
      将指定的元素插入到此队列中，等待空格可用。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>int</code></td> 
   <td><code><span><a rel="nofollow">remainingCapacity</a></span>()</code> 
    <div>
      返回该队列最好可以（在没有存储器或资源约束）接受而不会阻塞，或附加的元素的数量 
     <code>Integer.MAX_VALUE</code>如果没有固有的限制。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code>boolean</code></td> 
   <td><code><span><a rel="nofollow">remove</a></span>(<a title="class in java.lang" rel="nofollow">Object</a>&nbsp;o)</code> 
    <div>
      从该队列中删除指定元素的单个实例（如果存在）。 
    </div> </td> 
  </tr> 
  <tr> 
   <td><code><a title="type parameter in BlockingQueue" rel="nofollow">E</a></code></td> 
   <td><code><span><a rel="nofollow">take</a></span>()</code> 
    <div>
      检索并删除此队列的头，如有必要，等待元素可用。 
    </div> </td> 
  </tr> 
 </tbody> 
</table>

BlockingQueue接口多用在多线程生产者-消费者问题中，在队列中没有元素时，可以进入阻塞状态，等待队列中有可用元素。

示例：

/**
     * 生产者
     */
    public class Producer implements Runnable{
        private final BlockingQueue queue;
        private int count=0;
        public Producer(BlockingQueue q){
            queue=q;
        }
    
        @Override
        public void run() {
            try {
                while(!Thread.interrupted()){
                    queue.put(produce());
                }
            } catch (InterruptedException e) {
    
            }
        }
        Object produce(){
            count++;
            return "第"+count+"个任务";
        }
    }

/**
     * 消费者
     */
    public class Consumer implements Runnable{
        private final BlockingQueue queue;
        public Consumer(BlockingQueue q){
            queue=q;
        }
    
        @Override
        public void run() {
            try {
                while(true){
                    consume(queue.take());
                }
            } catch (InterruptedException e) {
    
            }
        }
        public void consume(Object x){
            System.out.println(x);
        }
    }

public class Main {
        public static void main(String[] args){
            BlockingQueue queue=new ArrayBlockingQueue(10);
            Producer pro=new Producer(queue);
            Consumer con=new Consumer(queue);
            //开始生产
            Thread a=new Thread(pro);
            a.start();
            //开始消费
            new Thread(con).start();
            try {
                TimeUnit.MILLISECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            a.interrupt();
        }
    }

第1个任务  
第2个任务  
第3个任务  
第4个任务  
第5个任务  
第6个任务  
第7个任务  
第8个任务  
第9个任务  
第10个任务  
第11个任务  
第12个任务  
第13个任务  
第14个任务  
第15个任务  
第16个任务  
第17个任务  
第18个任务  
第19个任务  
第20个任务  
第21个任务  
第22个任务  
第23个任务  
第24个任务  
第25个任务  
第26个任务  
第27个任务  
第28个任务  
第29个任务  
第30个任务  
第31个任务  
第32个任务  
第33个任务