- 浏览: 86118 次
- 性别:
- 来自: 北京
-
文章分类
最新评论
-
ssy341:
说的简单了点,和官网的文档差不多,多文件上传也不是很好,不过可 ...
jQuery插件AjaxFileUpload文件上传实现Javascript多文件上传功能 -
蓝凝幽偌:
有没有jar包?
org.apache.commons.net.ftp.FTPClient 的简单用法 -
tinguo002:
在这里缓缓走过,很为楼主钻研精神感动,也感谢楼主分享。
关于Struts2资源文件的配置
由于LinkedBlockingQueue 实现是线程安全的,实现了先进先出等特性,是作为生产者消费者的首选,LinkedBlockingQueue 可以指定容量,也可以不指定,不指定的话,默认最大是Integer.MAX_VALUE,其中主要用到put和take方法,put方法在队列满的时候会阻塞直到有队列成员被消费,take方法在队列空的时候会阻塞,直到有队列成员被放进来。下面是一个例子,一看就明白了。
package com.spell.designPattern.producer_consumer;
import java.util.UUID;
import java.util.concurrent.BlockingQueue;
/**
* 生产者类,任务是产生个uuid放在队列中
*
* @author Administrator
*
*/
public class Producer implements Runnable {
private BlockingQueue<String> queue;
public Producer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
String uuid = UUID.randomUUID().toString();
try {
queue.put(uuid);
System.out
.println(Thread.currentThread() + " produce uuid:" + uuid);
} catch (InterruptedException e) {
System.out.println(e.getMessage());
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.concurrent.BlockingQueue;
/**
* 消费者队列,任务是取得队列中的uuid打印下
*
* @author Administrator
*
*/
public class Consumer implements Runnable {
private BlockingQueue<String> queue;
public Consumer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
try {
String uuid = queue.take();
System.out
.println(Thread.currentThread() + " consume uuid:" + uuid);
} catch (InterruptedException e) {
System.out.println(e.getMessage());
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.concurrent.LinkedBlockingQueue;
/**
* 测试类
*
* @author Administrator
*
*/
public class Tester {
public static void main(String[] args) throws InterruptedException {
// 队列
LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(10);
// 生产者一号
Producer producer = new Producer(queue);
// 生产者二号
Producer producer2 = new Producer(queue);
// 消费者
Consumer consumer = new Consumer(queue);
for (int i = 0; i < 15; i++) {
new Thread(producer).start();
}
for (int i = 0; i < 15; i++) {
new Thread(producer2).start();
}
for (int i = 0; i < 30; i++) {
new Thread(consumer).start();
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.UUID;
import java.util.concurrent.BlockingQueue;
/**
* 生产者类,任务是产生个uuid放在队列中
*
* @author Administrator
*
*/
public class Producer implements Runnable {
private BlockingQueue<String> queue;
public Producer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
String uuid = UUID.randomUUID().toString();
try {
queue.put(uuid);
System.out
.println(Thread.currentThread() + " produce uuid:" + uuid);
} catch (InterruptedException e) {
System.out.println(e.getMessage());
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.concurrent.BlockingQueue;
/**
* 消费者队列,任务是取得队列中的uuid打印下
*
* @author Administrator
*
*/
public class Consumer implements Runnable {
private BlockingQueue<String> queue;
public Consumer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
try {
String uuid = queue.take();
System.out
.println(Thread.currentThread() + " consume uuid:" + uuid);
} catch (InterruptedException e) {
System.out.println(e.getMessage());
}
}
}
package com.spell.designPattern.producer_consumer;
import java.util.concurrent.LinkedBlockingQueue;
/**
* 测试类
*
* @author Administrator
*
*/
public class Tester {
public static void main(String[] args) throws InterruptedException {
// 队列
LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(10);
// 生产者一号
Producer producer = new Producer(queue);
// 生产者二号
Producer producer2 = new Producer(queue);
// 消费者
Consumer consumer = new Consumer(queue);
for (int i = 0; i < 15; i++) {
new Thread(producer).start();
}
for (int i = 0; i < 15; i++) {
new Thread(producer2).start();
}
for (int i = 0; i < 30; i++) {
new Thread(consumer).start();
}
}
}
发表评论
-
java编程思想final的理解
2015-03-06 13:38 328根据上下文环境,java的关键字final也存在着细微的区别, ... -
PDF2SWF中文字符集解决方案
2014-02-26 15:12 800转自:http://www.cnblogs.com/liver ... -
Runtime.getRuntime().exec() 输出流阻塞的解决方法
2014-02-26 09:40 1824转自:http://blog.csdn.net/xiaoani ... -
笔记(不用老搜索了)
2013-07-17 16:16 0下面代码则执行了subgo()函数, <a href ... -
加密123
2013-05-08 22:35 795/** * 加密传输时的密码 * @author weirhp ... -
jsoup解析
2013-04-28 15:31 652http://www.ibm.com/developerwor ... -
java线程管理利器:java.util.current的用法举例
2012-12-05 15:42 980DK5中增加了Doug Lea的并发库,这一引进给java线程 ... -
Tomcat - 解决which must be escaped when used within the value错误
2012-11-19 15:17 632http://www.cnblogs.com/javadu/a ... -
Java POI Word 写文档
2012-11-09 09:19 8071 package apache.poi; 2 3 ... -
使用COS组件实现文件上传
2012-06-15 11:25 1461转自:http://blog.csdn.net/jadyer/ ... -
Java Annotation(1)
2011-06-19 09:48 637作者:曾巧(numenzq) 摘要 Annotation( ... -
关于request得到路径的几种方法
2011-06-08 15:43 922request.getRequestURI() /jque ... -
JAVA EXCEL API 简介
2011-04-18 16:32 701转自:http://www.ibm.com/dev ... -
Hibernate 多对多双向关联
2011-03-21 11:09 598Hibernate 多对多双向关联 一、模型介绍 多个 ... -
Hibernate 一对多连接表双向关联
2011-03-21 11:09 741Hibernate 一对多连接表双向关联 一、模型介绍 ... -
Hibernate 一对多外键双向关联
2011-03-21 11:08 752Hibernate 一对多外键双向关联 一、模型介绍 ... -
Hibernate 一对一主键双向关联
2011-03-21 11:07 685Hibernate 一对一主键双向关联 一对一主键映射在一 ... -
Hibernate 一对一外键双向关联
2011-03-21 11:07 619Hibernate 一对一外键双向关联 一对一外键关联是一 ... -
Hibernate 多对多单向关联
2011-03-21 11:06 614Hibernate 多对多单向关联 一、模型介绍 多个人( ... -
Hibernate 多对一连接表单向关联
2011-03-21 11:05 634Hibernate 多对一连接表单向关联 一、模型介绍 ...
相关推荐
这种方式简化了生产者消费者的实现,如ArrayBlockingQueue、LinkedBlockingQueue等。 生产者消费者模式的流程如下: - 生产者在仓储未满时生产产品,并将其放入缓冲区。 - 消费者在仓储有产品时进行消费,若无...
NULL 博文链接:https://xiongjiajia.iteye.com/blog/2325943
"并发容器之ArrayBlockingQueue和LinkedBlockingQueue实现原理详解" ArrayBlockingQueue和LinkedBlockingQueue是Java并发容器中两个常用的阻塞队列实现,分别基于数组和链表存储元素。它们都继承自AbstractQueue类...
Java多线程中,生产者消费者模型是非常重要的一种设计模式,它可以解决多线程之间的数据传输问题。在Java中,我们可以使用BlockingQueue来实现生产者消费者模型,BlockingQueue是Queue的子类,它提供了一个线程安全...
总结来说,Java多线程中的生产者与消费者问题是并发编程中常见的场景,解决这类问题通常需要利用线程同步机制,如`synchronized`关键字、`wait/notify`机制,以及高级并发工具如`BlockingQueue`。理解和熟练运用这些...
BlockingQueue的应用场景非常广泛,如在多线程应用中,用于实现生产者消费者模式、消息队列、缓存等。在实际项目中,可以根据需要选取适合的BlockingQueue实现和处理方法。 通过 BlockingQueue,可以实现以下几个...
生产消费者模式是一种经典的多线程设计模式,用于解决生产者(生产数据)与消费者(消费数据)之间的同步问题,确保生产者不会在消费者未准备好时过度生产,同时消费者也不会在没有数据可消费时浪费资源。...
源码:BlockingQueue实现生产者消费者模式→ 输出结果截图 1. Queue接口 – 队列 public interface Queue extends Collection Collection的子接口,表示队列FIFO(First In First Out) 常用方法: (1)抛出异常...
linkedblockingqueue测试程序
首先 LinkedBlockingQueue 是一个 “可选且有界” 的阻塞队列实现,你可以根据需要指定队列的大小。 接下来,我将创建一个 LinkedBlockingQueue ,它最多可以包含100个元素: BlockingQueue<Integer> ...
阻塞队列和⽣产者-消费者模式是指在多线程环境下,使用阻塞队列来实现生产者-消费者模式。例如,在桌⾯搜索时,使用阻塞队列来实现生产者-消费者模式,以确保线程安全。 实例1 桌⾯搜索是指在桌⾯搜索时,使用多...
面试时,可能会被问到如何使用它们实现生产者-消费者模型,或者如何在并发环境下解决数据同步问题,因此深入理解这些接口和它们的方法是非常重要的。在使用时,选择合适的实现类,如`ArrayBlockingQueue`, `...
1. **生产者-消费者模式**: 生产者-消费者模式是一种多线程同步问题的经典解决方案。在这个模式中,生产者负责创建资源,然后放入共享的缓冲区,而消费者则从缓冲区取出资源进行消费。在Java中,可以使用`java....
【2018最新最详细】并发多线程教程,课程结构如下 1.并发编程的优缺点 2.线程的状态转换以及基本操作 3.java内存模型以及happens-before规则 4.彻底理解synchronized ...27.一篇文章,让你彻底弄懂生产者--消费者问题
在多线程编程中,阻塞队列常用于实现生产者-消费者模型,其中生产者线程负责向队列中添加元素,消费者线程则负责消费这些元素。由于阻塞队列能自动处理线程间的同步,因此可以简化代码并提高系统的可伸缩性。此外,...
并发队列ConcurrentLinkedQueue和阻塞队列LinkedBlockingQueue用法
Java并发集合LinkedBlockingQueue是Java并发集合中的一种阻塞队列实现,使用链表方式实现的阻塞队列。LinkedBlockingQueue的实现主要包括链表实现、插入和删除节点、同步锁和条件等几个方面。 一、链表实现 ...
LinkedBlockingQueuejava.pdf