BlockingQueue实现生产者、消费者模式

BlockingQueue可以作为线程间数据共享通道,它会让服务线程在队列为空时进行等待,而当有新消息进入队列后,自动将线程唤醒。 向队列添加数据可以使用offer()方法或put()方法,它们都是向队列尾部添加元素,区别在于如果队列满了offer返回false,而put会一直等待。相对的取出元素可以使用poll()方法或take()方法,它们都从队列头部获得一个元素,区别在于如果队列为空poll
相关文章
相关标签/搜索