大家好,我是顺亿。今天我们来聊聊Java中的BlockingQueue,这个家伙在处理大批量数据入库的时候可是大有用处哦!
在开发过程中,我们经常会遇到需要处理大量数据的情况。这时候,队列就派上用场了。我们可以先把数据写入队列,然后开启多个消费线程慢慢处理。从队列中消费数据主要有两种方式:单条消费和批量消费。接下来,我们就来分别实现这两种方式。
首先,存数据到队列比较简单,我推荐使用BlockingQueue,它是一个阻塞队列。
// 创建队列
BlockingQueue blockingQueue = new ArrayBlockingQueue<>(1000000,true);
/**
* 向队列中存放数据
* @param message
*/
public void saveQueueData(String message){
// 存放数据
blockingQueue.offer(
