跳转到主内容
趣航编程网 - 趣学编程,启航技术之路!

Java批量消费队列(BlockingQueue)怎么玩?

大家好,我是顺亿。今天我们来聊聊Java中的BlockingQueue,这个家伙在处理大批量数据入库的时候可是大有用处哦!

在开发过程中,我们经常会遇到需要处理大量数据的情况。这时候,队列就派上用场了。我们可以先把数据写入队列,然后开启多个消费线程慢慢处理。从队列中消费数据主要有两种方式:单条消费和批量消费。接下来,我们就来分别实现这两种方式。

首先,存数据到队列比较简单,我推荐使用BlockingQueue,它是一个阻塞队列。

// 创建队列  
BlockingQueue blockingQueue = new ArrayBlockingQueue<>(1000000,true);  
  
/**  
 * 向队列中存放数据  
 * @param message  
 */  
public void saveQueueData(String message){  
 // 存放数据  
 blockingQueue.offer(
                            

相关文章