Java5实现阻塞队列

浅浅的花香味﹌ 2022-06-13 10:20 160阅读 0赞

import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    
    class BoundedBuffer
    {
    	final Lock		lock		= new ReentrantLock();
    	final Condition	notFull		= lock.newCondition();
    	final Condition	notEmpty	= lock.newCondition();
    
    	final Object[]	items		= new Object[100];
    	int				putptr, takeptr, count;
    
    	public void put(Object x) throws InterruptedException
    	{
    		lock.lock();
    		try
    		{
    			while (count == items.length)
    			{
    				notFull.await();
    			}
    			
    			items[putptr] = x;
    			
    			if(++putptr == items.length)
    			{
    				putptr = 0;
    			}
    			
    			++count;
    			
    			notEmpty.signal();
    		}
    		finally
    		{
    			lock.unlock();
    		}
    	}
    
    	public Object take() throws InterruptedException
    	{
    		lock.lock();
    		try
    		{
    			while (count == 0)
    			{
    				notEmpty.await();
    			}
    			
    			Object x = items[takeptr];
    			
    			if(++takeptr == items.length)
    			{
    				takeptr = 0;
    			}
    			
    			--count;
    			
    			notFull.signal();
    			
    			return x;
    		}
    		finally
    		{
    			lock.unlock();
    		}
    	}
    }

发表评论取消回复

表情：

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

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

相关阅读

相关阻塞队列实现

阻塞队列是⼀种特殊的队列，遵守 “先进先出” 的原则。当队列满的时候，继续⼊队列就会阻塞，直到有其他线程从队列中取⾛元素。当队列空的时候，继续出队列也会阻塞，直到有其他线...

旧城等待，/ 2024年04月23日 21:19/ 0 赞/ 58 阅读

相关【Java】阻塞队列

【Java】阻塞队列什么是阻塞队列？阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这2个附加的操作支持阻塞的插入和移除方法。支持

左手的ㄟ右手/ 2024年03月30日 16:27/ 0 赞/ 77 阅读

相关 Java阻塞队列

目录一、什么是阻塞队列二、阻塞队列的使用阻塞队列类中的常用方法三、模拟实现阻塞队列 -------------------- 一、什么是阻塞队列阻塞

心已赠人/ 2024年02月05日 17:15/ 0 赞/ 42 阅读

相关 Java实现阻塞队列

import java.util.LinkedList; import java.util.Queue; import java.util.Timer;

太过爱你忘了你带给我的痛/ 2022年12月31日 10:21/ 0 赞/ 132 阅读

相关 java 之阻塞队列

队列 > 队列是一种特殊的线性表，特殊之处在于它只允许在表的前端（front）进行删除操作，而在表的后端（rear）进行插入操作，和栈一样，队列是一种操作受限制的线性表。

我不是女神ヾ/ 2022年08月31日 02:27/ 0 赞/ 171 阅读

相关 C++阻塞队列实现

阻塞队列是后台开发中多线程异步架构的基本数据结构，像python, java 都提供线程安全的阻塞队列，c++ 可能需要自己实现一个模板。从性能考虑，自己没有使用STL的q

太过爱你忘了你带给我的痛/ 2022年08月20日 12:09/ 0 赞/ 128 阅读

相关 Java5实现阻塞队列

import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.L

浅浅的花香味﹌/ 2022年06月13日 10:20/ 0 赞/ 161 阅读

相关 Java 阻塞队列（BlockingQueue）

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

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

相关实现ArrayBlockingQueue-阻塞队列

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][] 一：基本特性二：实现原理三：实现代码一：基本

左手的ㄟ右手/ 2022年01月16日 04:25/ 0 赞/ 317 阅读

相关 Java实现阻塞队列+生产者消费者

Java实现阻塞队列 package test.blockqueue; import java.util.concurrent.locks.Co

﹏ヽ暗。殇╰゛Y/ 2021年09月21日 05:26/ 0 赞/ 370 阅读