生产者与消费者，看下例： local?function?producer()
?????return?coroutine.create(
?????function(cookie)
??????????print("cookie?=?",cookie)
??????????local...
分类：
其他好文 时间：
2015-07-29 19:55:52
阅读次数：
131
BlockingQueue、BoundedBlockingQueue是关于有界缓冲和无界缓冲的，是典型的生产者消费者模型的代表。...
分类：
数据库 时间：
2015-07-29 17:24:26
阅读次数：
248
struct node{
struct node *next;
int data;
}struct node *queue;//队列头多个消费者（多线程）都需要向这个queue插入数据
为了说明问题的复杂性，先看看只有一个消费者时的情况，插入队列的操作非常简单：
Step1) new_head->next = queue->head;
Step2) queue->head = n...
分类：
其他好文 时间：
2015-07-27 23:03:03
阅读次数：
262
连接工厂创建连接对象的工厂。连接客户端与 JMS 服务器之间建立的连接。创建一个或多个会话。会话创建消息、生产者和消费者，会话是消息由三部分组成：消息头、消息属性和消息体。生产者创建和发送消息。消费者接收和处理消息。目的地生产者消息发送的目标，亦或是消费者消息接收的来源。根据消息模型可分为队列和主题...
分类：
其他好文 时间：
2015-07-27 22:49:32
阅读次数：
222
一：概述实际学习和工作中，我们经常会遇到读写大量数据的情况，这个时候我们可能就用到了循环缓冲区。循环缓冲区在处理大量数据的时候有很大的优点，循环缓冲区在一些竞争问题上提供了一种免锁的机制，免锁的前提是，生产者和消费都只有一个的情况下，否则也要加锁。二：循环缓冲区的实现理论如下图三：实现代码如下所示：...
分类：
编程语言 时间：
2015-07-27 01:49:15
阅读次数：
214
1.1 JMS简介
JMS的全称是Java Message Service，即Java消息服务。它主要用于在生产者和消费者之间进行消息传递，生产者负责产生消息，而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息，并进行发送，对应的消费者在接收到对应的消息后去完成对应的业务逻辑。对于消息的传递有两种类型，一种是点对点的，即一个生产者和...
分类：
编程语言 时间：
2015-07-26 22:39:13
阅读次数：
236
线程同步-信号量(semaphore)
生产者与消费者问题再思考
在实际生活中，只要有商品，消费者就可以消费，这没问题。但生产者的生产并不是无限的，例如，仓库是有限的，原材料是有限的，生产指标受消费指标限制等等。为了进一步，解决好生产者与消费者问题，引入信号量进机制。
信号量
信号量(semaphore)是互斥量的升级版：互斥量的状态为0或1，而信号量可以为n。也就是说，使用互斥量时，最多允许一个线程进入关键区，而信号量允许多个，具体值是信号量当前的内部值。
相关函数...
分类：
编程语言 时间：
2015-07-26 19:17:13
阅读次数：
175
线程同步-条件变量
生产者与消费者问题
再引入条件变量之前，我们先看下生产者和消费者问题：生产者不断地生产产品，同时消费者不断地在消费产品。
这个问题的同步在于两处：第一，消费者之间需要同步：同一件产品只可由一人消费。第二，当无产品可消费时，消费者需等待生产者生产后，才可继续消费，这又是一个同步问题。详细了解：生产者消费者问题。
条件变量
条件变量是利用线程间共享的全局变量进行同步的一种机制，并且条件变量总是和互斥锁结合在一起。
相关函数...
分类：
编程语言 时间：
2015-07-26 12:46:01
阅读次数：
518
我们常用wait()，notify()和notifyAll()方法来进行线程间通信。线程检查一个条件后就行进入等待状态，例如，在“生产者-消费者”模型中，生产者线程发现缓冲区满了就等待，消费者线程通过消费一个产品使得缓冲区有空闲并通知生产者线程。notify()或notifyAll()的调用给一个或多个线程发出通知，告诉它（它们）条件已经发生改变，并且，一旦通知线程离开同步块，所有等待这个对象锁的...
分类：
其他好文 时间：
2015-07-26 00:35:34
阅读次数：
3183
1 package ThreadL; 2 3 import java.util.LinkedList; 4 5 class Queue extends LinkedList{ 6 int lenght; 7 public Queue(){ 8 ...
分类：
其他好文 时间：
2015-07-25 19:49:37
阅读次数：
104
