阻塞队列 BlockingQueue LinkedBlockingQueue

素颜马尾好姑娘i 2022-08-26 14:28 218阅读 0赞

package com.ctl.util.ThreadPool;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.LinkedBlockingQueue;
    import java.util.concurrent.TimeUnit;
    
    /*阻塞队列* */
    public class Demo04 {
    	Thread tom;// tom receive
    	Thread jerry;// jerry send
    	BlockingQueue<String> queue;
    
    	class Tom extends Thread {
    		public void run() {
    			while (true) {
    					try {
    						String msg=queue.poll(1, TimeUnit.SECONDS);
    						if(msg==null){continue;}
    						System.out.println("Tom receive:   "+msg);
    						Thread.sleep(3000);
    					} catch (InterruptedException e) {
    						System.err.println("InterruptedException"+e);
    					}
    			}
    		}
    	}
    
    	class Jerry extends Thread {
    		int i = 0;
    
    		public void run() {
    			while (true) {
    				String hello = "HI!" + i;
    				try {
    					// 如果等待5秒插入失败返回false成功返回true
    					boolean success = queue.offer(hello, 2, TimeUnit.SECONDS);
    					// 如果插入成功 i++ 否则继续插入
    					if (success) {
    						System.out.println("添加信息成功\t"+hello);
    						i++;
    					} else {
    						System.out.println("满了，重试");
    						continue;
    					}
    				} catch (InterruptedException e) {
    					System.err.println("InterruptedException" + e);
    				}
    			}
    		}
    	}
    
    	public void start() {
    		queue = new LinkedBlockingQueue<String>(3);// 超过3个就满了
    		tom = new Tom();
    		jerry = new Jerry();
    		tom.start();
    		jerry.start();
    	}
    
    	public static void main(String[] args) {
    		new Demo04().start();
    	}
    
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，218人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java队列之阻塞队列LinkedBlockingQueue

LinkedBlockingQueue是BlockingQueue中的其中一个，其实现方式为单向链表，下面看其具体实现。（均为JDK8）一、构造函数在LinkedB

喜欢ヅ旅行/ 2022年12月26日 10:15/ 0 赞/ 188 阅读

相关 JUC阻塞队列BlockingQueue

前言：最近面试和手动创建线程池时都用到了阻塞队列，不由得产生好奇，探究一下原理参考： [https://www.cnblogs.com/tjudzj/p/4454490.

绝地灬酷狼/ 2022年12月11日 09:12/ 0 赞/ 231 阅读

相关 BlockingQueue（阻塞队列）详解

一. 前言　　在新增的Concurrent包中，BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类，为我们快速

左手的ㄟ右手/ 2022年12月04日 01:19/ 0 赞/ 144 阅读

相关 BlockingQueue阻塞队列

BlockingQueue简介 Concurrent包中，BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类

朱雀/ 2022年09月08日 00:16/ 0 赞/ 236 阅读

相关 BlockingQueue阻塞队列

BlockingQueue简介阻塞队列，顾名思义，首先它是一个队列, 通过一个共享的队列，可以使得数据由队列的一端输入，从另外一端输出；当队列是空的，从队列中获取元

落日映苍穹つ/ 2022年08月28日 13:49/ 0 赞/ 248 阅读

相关阻塞队列 BlockingQueue LinkedBlockingQueue

package com.ctl.util.ThreadPool; import java.util.concurrent.BlockingQueue;

素颜马尾好姑娘i/ 2022年08月26日 14:28/ 0 赞/ 219 阅读

相关 BlockingQueue（阻塞队列）详解

一. 前言　　在新增的Concurrent包中，BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类，为我们快速

淡淡的烟草味﹌/ 2022年06月10日 08:07/ 0 赞/ 295 阅读

相关 Java 阻塞队列（BlockingQueue）

BlockingQueue是java中的阻塞队列，它是线程安全的。在队列为空时的获取阻塞，在队列满时的放入阻塞。 BlockingQueue方法以四种形式出现

客官°小女子只卖身不卖艺/ 2022年03月17日 18:30/ 0 赞/ 320 阅读

相关 Java集合--阻塞队列（LinkedBlockingQueue）

Java集合–阻塞队列（LinkedBlockingQueue） 1. LinkedBlockingQueue LinkedBlockingQueue是一个使用链表

本是古典何须时尚/ 2022年03月12日 19:48/ 0 赞/ 202 阅读

相关阻塞队列BlockingQueue

> 固定长度的队列往里放数据，如果放满了还要放，阻塞式队列就会等待，直到有数据取出，空出位置后才继续放；非阻塞式队列不能等待就只能报错了。多线程环境中，通过队列可以很容易实

小咪咪/ 2021年09月29日 15:16/ 0 赞/ 399 阅读