java多线程消费队列_java队列详解「建议收藏」

一、什么是Queue

什么是Java编程中的Queue(队列)详细介绍请参考上一篇：Java Queue队列使用入门详解 该文章详细讲解了Java编程中的queue是什么，基本的操作等。

二、Java中Queue如何实现生产消费模式

以下为队列服务代码：

$title(QueneService.java)

package com.example.demospringbootblockingqueue.test;

import java.util.concurrent.LinkedBlockingQueue;

/***

* 队列服务

*/

public class QueneService {

private static LinkedBlockingQueue queue = new LinkedBlockingQueue<>();

/**

* 获取队列信息

*

* @return

*/

LinkedBlockingQueue getQueue() {

return queue;

}

}

可以看到上面的代码非常简单就是一个Java的list集合对象

接下来就是生产者了：

$title(Producer.java)

package com.example.demospringbootblockingqueue.test;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

/**

* 生产数据

*/

public class Producer {

QueneService queneService;

public Producer(QueneService queneService){

this.queneService=queneService;

}

public void createPersion(Persion persion){

try {

queneService.getQueue().add(persion);

}catch (Exception e){

System.out.println(“数据添加到队列错误。”);

}