一、生产者消费者模式的学生类成员变量生产与消费demo，第一版1、等待唤醒： Object类中提供了三个方法： wait():等待 notify():唤醒单个线程 notifyAll():唤醒所有线程2、为什么这些方法不定义在Thread类中呢? 这些方法的调用必须通过锁对象调用，而我们刚才使用的锁 ...
分类：
编程语言 时间：
2016-04-25 20:57:15
阅读次数：
214
1、在毕老师的视频里，首先介绍的是synchronized关键字作为同步，紧接着在多生产者和多消费者的例子当中就引出了Lock接口和Condition接口。而在书中是先介绍的Lock核Condition接口。我感觉Lock和Con接口比较复杂，相比于synchronized关键字来说需要做的事情太多 ...
分类：
编程语言 时间：
2016-04-25 17:59:48
阅读次数：
236
一，背景 近期需要用到ActiveMQ接收Oozie执行作业之后的返回结果。Oozie作为消息的生产者，将消息发送给ActiveMQ，然后Client可以异步去ActiveMQ取消息。 ActiveMQ作为基于 JMS 开源的Apache Message Provider，故记录下JMS相关基础知识 ...
分类：
编程语言 时间：
2016-04-25 17:56:26
阅读次数：
316
信号量和Mutex类似，表示可用资源的数量，和Mutex不同的是，这个数量可以大于1，即如果信号量描述的资源数目是1时，此时的信号量和互斥锁相同。下面我们看看POSIXsemaphore库函数，它既可以用于同一进程的线程间同步，也可以用于不同进程间的同步。1.intsem_init（sem_t*sem，i..
分类：
其他好文 时间：
2016-04-25 01:11:34
阅读次数：
326
一.基础知识1.1systemV版本的信号量和POSIX下信号量的区别我们前面讲过进程间通信有三种形式：管道、消息队列、信号量。这个信号量是systemV版本下，以信号量集形式申请存在的，它标识着一个临界资源的有无从而控制不同的进程能否访问到该临界资源。但，现在，我们要讲的信号量..
分类：
其他好文 时间：
2016-04-25 01:09:49
阅读次数：
353
BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类，为我们快速搭建高质量的多线程程序带来极大的便利。使用场景。 首先它是一个队列，而一个队列在数据结构中所起的作用大致如下图所示： 通过一个共享的队列，可以使得数据由队列的一端输入，从另外一 ...
分类：
其他好文 时间：
2016-04-24 23:13:24
阅读次数：
337
一、生产消费模型：我们可以用条件变量来实现线程之间的同步，利用一个生产消费模型具体的实现同步。生产消费模型可以简单地称为3,2,1模型（即3种关系，2个对象，1个场所），同时还需注意以下3点：1、生产者和消费者是同步互斥关系；2、生产者和生产者是互斥关系；3、消费者和..
分类：
编程语言 时间：
2016-04-24 19:00:45
阅读次数：
319
死锁产生的四个条件：1、互斥使用（资源独占）一个资源每次只能给一个进程使用.2、不可强占（不可剥夺）资源申请者不能强行的从资源占有者手中夺取资源，资源只能由占有者自愿释放.3、请求和保持（部分分配，占有申请）一个进程在申请新的资源的同时保持对原有资源的占有（只有..
分类：
编程语言 时间：
2016-04-24 18:57:59
阅读次数：
232
告警系统架构如下 1、 数据处理系统处理完原始数据并入库后，发送消息到kafka系统； 2、 告警生产者从kafka系统查询消息存入告警消息队列； 3、 告警消费者从告警消息队列查询消息进行处理。 这显然是生产者消费者模型，一个告警消息生产者，多个告警消息消费者。生产者生产消息过快会产生消息积压，生 ...
分类：
其他好文 时间：
2016-04-24 18:49:17
阅读次数：
139
JMS的全称是Java Message Service，即Java消息服务。它主要用于在生产者和消费者之间进行消息传递，生产者负责产生消息，而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息，并进行发送，对应的消费者在接收到对应的消息后去完成对应的业务逻辑。 ...
分类：
编程语言 时间：
2016-04-24 12:44:19
阅读次数：
331
