应用场景: 典型的生产者-消费者模式, 目前虽已实现,但存在一些问题,准备更换成MSMQ. 多个生产者(producer)应用从业务平台拉取订单放入队列应用(QueueManager)(自己实现), 多个消费者(consumer)应用从队列应用中每次取出1笔订单进行处理,处理完成后直接向业务平台返回 ...
分类：
其他好文 时间：
2016-07-15 19:28:50
阅读次数：
160
利用ArrayBlockingQueue可以方便的实现生产者和消费者,所有消费者线程共用资源ArrayBlockingQueue对象,从而实现线程安全.生产者线程搜索当前目录及子目录,并且将相应的File对象添加到队列中,消费者线程对每个File对象进行关键字的查询,如果查到头,即停止查询. ...
分类：
编程语言 时间：
2016-06-30 23:17:51
阅读次数：
149
欢迎转载，转载请注明出处。尊重他人的一丢丢努力，谢谢啦！
阅读本篇之后，如果你觉得说得还有点道理，那不妨先戳一下从生产者消费者窥探线程同步（下） ，两篇一起嚼才更好呢。最近复习了下生产者消费者模式，虽然对它不太陌生，但要说认认真真地实现，还真从来没有过，这里将它总结一下，有不妥或者见识不到之处，欢迎留言指出。为什么要使用大概基于以下2点：
（1）可以实现解耦
大多数设计模式，都会创造出一个第...
分类：
编程语言 时间：
2016-06-21 07:57:01
阅读次数：
211
欢迎转载，转载请注明出处。尊重他人的一丢丢努力，谢谢啦！
阅读本篇之前，如果你还没有看过从生产者消费者窥探线程同步（上）
，那不妨先戳一下，两篇一起嚼才更好呢。上一篇分析了使用BlockQueue和synchronized来实现生产者消费者模式。这一篇来看一下其他的实现，闲言少叙。（3）Lock实现核心：Lock的用法中规中矩，有点类似于非静态同步方法，只是前者是对lock对象显式加锁，而后者是...
分类：
编程语言 时间：
2016-06-20 10:06:37
阅读次数：
365
1、实现生产者/消费者模式：一对一交替打印
public class MyService {
private ReentrantLock lock= new ReentrantLock();
private Condition condition = lock.newCondition();
private boolean hasValue = false;
p...
分类：
编程语言 时间：
2016-05-13 03:33:38
阅读次数：
271
package com.git.base.thread.productandconsumer;
/**
* 核心实现:
* 生产者消费者模式:
* 生产一个,消费一个,如果生产未被消费,那么就等待消费后再生产
* 如果消费后,没有下一个生产的,就等待生产后在消费
* Title: DoMain.java
* Description:
* Copyright: Copyright (...
分类：
编程语言 时间：
2016-05-12 18:01:51
阅读次数：
169
生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。
生产者消费者模式的优点- 解耦
- 支持并发
- 支持忙闲不均
解决方法可分为两类：
（1）用信号量和锁机制实现生产者和消费者之间的同步；
- wait() / notify()方法
- await() / signal()方法
- BlockingQu...
分类：
编程语言 时间：
2016-04-29 19:45:09
阅读次数：
254
不得不说，本人工作上很少有使用多线程技术的地方。由于本人工作上经常使用的是类似SSH等框架搭建MVC架构，所以更加习惯于编写一些优秀程序员所唾弃的样板式的代码。最近看了文海的多线程编程实战指南，瞬间眼前一亮。觉得有很多自己可以学习的，事实上，我已经在最近的项目中使用上了那本书介绍的两相终止模式、串行封闭模式、生产者消费者模式以及线程池等技术，确实在许多方面改进了我们服务端的吞吐量。说到这里本人吐槽...
分类：
编程语言 时间：
2016-04-29 16:36:55
阅读次数：
307
二、生产者消费者模式的学生类成员变量生产与消费demo， @Version2.0 在学生类中添加同步方法：synchronized get（）消费者，synchronized set（）生产者 最终版的代码中： 把student的成员变量给私有化了， 把设置和获取的功能给封装成了功能，并加了同步， ...
分类：
编程语言 时间：
2016-04-25 21:01:07
阅读次数：
178
一、生产者消费者模式的学生类成员变量生产与消费demo，第一版1、等待唤醒： Object类中提供了三个方法： wait():等待 notify():唤醒单个线程 notifyAll():唤醒所有线程2、为什么这些方法不定义在Thread类中呢? 这些方法的调用必须通过锁对象调用，而我们刚才使用的锁 ...
分类：
编程语言 时间：
2016-04-25 20:57:15
阅读次数：
214
