java根据wait,notify,synchronize关键字自定义队列

这里定义了一个有界队列 ,保证先进先出,在队列达到上限时应该阻塞,直到队列有元素被取出才能继续往里继续添加 完整代码:

package com.comic.queue;

import java.util.LinkedList;
import java.util.concurrent.atomic.AtomicInteger;

public class BoundedQueue {
	// 队列的最大值
	private int maxSize;
	// 计数器
	private AtomicInteger counter = new AtomicInteger(0);
	// 数据容器
	private LinkedList<Object> content = new LinkedList<Object>();
	// 琐
	private Object lock = new Object();

	public BoundedQueue(int maxSize) {
		this.maxSize = maxSize;
	}

	/**
	 * 入队列
	 * 
	 * @param obj
	 * @throws InterruptedException
	 */
	public void put(Object obj) throws InterruptedException {
		synchronized (lock) {
			while (maxSize == counter.get()) {
				System.out.println("队列已满,请等待....");
				lock.wait();
			}
			// 添加元素,计数,唤醒线程
			content.add(obj);
			counter.getAndIncrement();
			lock.notify();
			System.out.println(obj + "入列");
		}

	}

	/**
	 * 取
	 * 
	 * @return
	 * @throws InterruptedException
	 */
	public Object take() throws InterruptedException {
		Object obj = null;
		synchronized (lock) {
			while (0 == counter.get()) {
				System.out.println("队列已空,请等待....");
				lock.wait();
			}
			// 获取第一个元素,计数,唤醒线程
			obj = content.get(0);
			content.remove(0);
			counter.decrementAndGet();
			lock.notify();
		}
		return obj;
	}

	public static void main(String[] args) throws InterruptedException {
		final BoundedQueue queue = new BoundedQueue(5);
		queue.put("aa");
		queue.put("bb");
		queue.put("cc");
		queue.put("dd");
		queue.put("ff");
		Thread t = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					queue.put("gg");
					queue.put("hh");
				} catch (Exception e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

			}
		}, "t1");
		t.start();
		
		Thread.sleep(500);
		System.out.println("**********************************");
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("take:" + queue.take());
					System.out.println("take:" + queue.take());
				} catch (Exception e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

			}
		}, "t2");
		t2.start();

	}

}

控制台部分: aa入列 bb入列 cc入列 dd入列 ff入列 队列已满,请等待.... ********************************** take:aa gg入列 队列已满,请等待.... take:bb hh入列

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏达摩兵的技术空间

当JSON.parse”遇上”非键值对

在json大行其道并作为前后端主要通讯的数据格式之一时,对json本身的使用和了解多少人都会有些概念,当然随之而来的也是对json的对象以及其字符串形式的互相转...

43430
来自专栏小李刀刀的专栏

Unicode编解码函数

在用XMLHTTP进行远程数据传输的时候,如果涉及到不同编码,比如从oblog向我的博客发送一个trackback ping,数据中包含的中文字符就会出现乱码。...

36450
来自专栏编码小白

ofbiz实体引擎(五) ModelGroupReader

public class ModelGroupReader implements Serializable { public static final...

36270
来自专栏施炯的IoT开发专栏

Microsoft Azure IoTHub Serials 2 - 如何为android应用添加IoTHub支持

1. 在build.gradle(app)文件的dependencies中添加对以下项的依赖:

14740
来自专栏F_Alex

数据结构与算法(六)-背包、栈和队列

  前言:许多基础数据类型都和对象的集合有关。具体来说,数据类型的值就是一组对象的集合,所有操作都是关于添加、删除或是访问集合中的对象。而且有很多高级数据结构都...

14240
来自专栏码匠的流水账

kafka0.8消费者实例

消费者实例数*每个实例的消费线程数 <= topic的partition数量,否则多余的就浪费了。

35610
来自专栏屈定‘s Blog

Java8 Lambda(三)-强大的collect操作

collect应该说是Stream中最强大的终端操作了,使用其几乎能得到你想要的任意数据的聚合,下面好好分析该工具的用法.

1.1K20
来自专栏码匠的流水账

聊聊storm的AggregateProcessor的execute及finishBatch方法

本文主要研究一下storm的AggregateProcessor的execute及finishBatch方法

8510
来自专栏码匠的流水账

聊聊flink的SourceFunction

flink-streaming-java_2.11-1.6.2-sources.jar!/org/apache/flink/streaming/api/func...

24320
来自专栏xingoo, 一个梦想做发明家的程序员

[Scala随用随学] —— sealed声明的作用

今天在看MLlib的源码时,看到Vector的声明是sealed trait,很好奇这个sealed有什么作用,与是搜到了这个文章:http://www.cnb...

20870

扫码关注云+社区

领取腾讯云代金券