生产者消费者问题是Java并发中的常见问题之一，在实现时，一般可以考虑使用juc包下的BlockingQueue接口，至于具体使用哪个类，则就需要根据具体的使用场景具体分析了。本文主要实现一个生产者消费者的原型，以及实现一个生产者消费者的典型使用场景。 第一个问题：实现一个生产者消费者的原型。 第二 ...
分类：
编程语言 时间：
2016-06-02 18:03:57
阅读次数：
227
如果你想避免使用错综复杂的wait–notify的语句，BlockingQueue非常有用。BlockingQueue可用于解决生产者-消费者问题，如下代码示例。对于每个开发人员来说，生产者消费者问题已经非常熟悉了，这里我将不做详细描述。 为什么BlockingQueue适合解决生产者消费者问题 任 ...
分类：
其他好文 时间：
2016-06-02 16:22:42
阅读次数：
265
JMS的全称是Java Message Service，即Java消息服务。它主要用于在生产者和消费者之间进行消息传递，生产者负责产生消息，而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息，并进行发送，对应的消费者在接收到对应的消息后去完成对应的业务逻辑。 ...
分类：
其他好文 时间：
2016-06-02 11:29:57
阅读次数：
1229
packagecom.yuanzijian01;
/*
*线程通讯：一个线程完成了自己的任务时，要通知另外一个线程去完成另外一个任务.
生产者与消费者
wait():等待如果线程执行了wait方法，那么该线程会进入等待的状态，等待状态下的线程必须要被其他线程调用notify方法才能唤醒。
notify()：唤..
分类：
编程语言 时间：
2016-06-02 00:56:27
阅读次数：
245
多线程环境中，通过队列可以很容易实现数据共享，比如经典的“生产者”和“消费者”模型中，通过队列可以很便利地实现两者之间的数据共享。 假设我们有若干生产者线程，另外又有若干个消费者线程。如果生产者线程需要把准备好的数据共享给消费者线程，利用队列的方式来传递数据，就可以很方便地解决他们之间的数据共享问题 ...
分类：
其他好文 时间：
2016-06-01 06:49:21
阅读次数：
166
队列相关资料:
http://chenjumin.iteye.com/blog/2182322
http://blog.csdn.net/luohuacanyue/article/details/16359777
Queue
------------
1.ArrayDeque, （数组双端队列）
2.PriorityQueue, （优先级队列）
3.Concurr...
分类：
编程语言 时间：
2016-05-30 15:42:14
阅读次数：
161
一、消息队列，简称MQ，message queue 生产者：生存数据写到kafka，持久化到硬盘。对同一个Topic来讲，生产者通常只有‘一个’（可以多并发）数据保存时常可以配置，默认保存七天。 消费者：从kafka里消费数据。对同一个Topic来讲，消费者会很多，根据业务需要。 kafka的消息分 ...
分类：
其他好文 时间：
2016-05-29 06:20:45
阅读次数：
496
［一］任务队列的好处 >松耦合：生产者和消费者无需知道彼此实现的细节，只需要约定好任务的描述格式。这使得生产者和消费者可以由不同的团队使用不同的编程语言编写。 >易于扩展：消费者可以有多个，而且可以分布在不同的机器。可以轻易降低单台服务器的负载。 ［二］使用redis实现简单的任务队列（生产者消费者 ...
分类：
其他好文 时间：
2016-05-27 14:27:49
阅读次数：
209
一，介绍 ActiveMQ的Transport Connectors 是什么？ ActiveMQ是一个消息服务器。作为消息服务器，就会有生产者和消费者来使用它。生产者将消息发送给ActiveMQ，消费者从ActiveMQ取消息。因此，不管是生产者还是消费者，都需要与ActiveMQ建立连接，从而交换 ...
分类：
其他好文 时间：
2016-05-25 13:07:42
阅读次数：
188
1.增大partition最大连接数 kafka的集群有多个Broker服务器组成，每个类型的消息被定义为topic，同一topic内部的消息按照一定的key和算法被分区(partition)存储在不同的Broker上，消息生产者producer和消费者consumer可以在多个Broker上生产/ ...
分类：
其他好文 时间：
2016-05-24 00:17:42
阅读次数：
270
