Java 6的并发编程包中的SynchronousQueue是一个没有数据缓冲的BlockingQueue，生产者线程对其的插入操作put必须等待消费者的移除操作take，反过来也一样。 不像ArrayBlockingQueue或LinkedListBlockingQueue，Synchronous ...
分类：
编程语言 时间：
2016-05-02 14:19:44
阅读次数：
331
生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。
生产者消费者模式的优点- 解耦
- 支持并发
- 支持忙闲不均
解决方法可分为两类：
（1）用信号量和锁机制实现生产者和消费者之间的同步；
- wait() / notify()方法
- await() / signal()方法
- BlockingQu...
分类：
编程语言 时间：
2016-04-29 19:45:09
阅读次数：
254
不得不说，本人工作上很少有使用多线程技术的地方。由于本人工作上经常使用的是类似SSH等框架搭建MVC架构，所以更加习惯于编写一些优秀程序员所唾弃的样板式的代码。最近看了文海的多线程编程实战指南，瞬间眼前一亮。觉得有很多自己可以学习的，事实上，我已经在最近的项目中使用上了那本书介绍的两相终止模式、串行封闭模式、生产者消费者模式以及线程池等技术，确实在许多方面改进了我们服务端的吞吐量。说到这里本人吐槽...
分类：
编程语言 时间：
2016-04-29 16:36:55
阅读次数：
307
上边代码主要介绍了java多线程解决生产者消费者问题的方法,实例分析了java采用多线程的方法解决生产者消费者问题的相关技巧,需要的朋友可以参考下 ...
分类：
编程语言 时间：
2016-04-27 12:59:54
阅读次数：
168
一、条件变量在线程同步过程中还有如下的情况：线程A需要等某个条件成立之后才能继续往下执行，如果条件不成立，线程A就阻塞，而线程B在执行过程中使这个条件成立了，就唤醒线程A继续执行。在Pthread库中用条件变量阻塞等待一个条件，或者唤醒等待这个条件的线程。条件变量用pt..
分类：
系统相关 时间：
2016-04-27 07:09:27
阅读次数：
325
posix下定义了一个semaphore，他和systemV版本下的sem很像，而这个多用于线程，它的单位是信号量，而sem的单位是信号量集。#include<semaphore.h>
intsem_init(sem_t*sem,intpshared,unsignedintvalue);
intsem_destroy(sem_t*sem);
intsem_wait(sem_t*sem);
intsem_try..
分类：
其他好文 时间：
2016-04-27 07:04:58
阅读次数：
194
基本配置metadata.broker.list：broker服务器集群列表，格式为host1:port1,host2:port2...producer.type：消息发送类型同步还是异步，默认为同步compression.codec：消息的压缩格式，默认为none不压缩，也可以为gzip,snappy,lz4serializer.class：消息加密格式，默认为kafka.se..
分类：
其他好文 时间：
2016-04-26 16:07:47
阅读次数：
146
背景 之前做日志收集模块时，用到flume。另外也有的方案，集成kafaka来提升系统可扩展性，其中涉及到消息队列当时自己并不清楚为什么要使用消息队列。而在我自己提出的原始日志采集方案中不适用消息队列时，有几个基本问题：1. 日志文件上传过程，有个基本的生产者-消费者问题；2. 另外系统崩溃时，数据 ...
分类：
其他好文 时间：
2016-04-26 09:28:55
阅读次数：
154
条件变量（conditionvariable）线程间的同步与互斥技术，主要以互斥锁和条件变量为主，条件变量和互斥所的配合使用可以很好的处理对于条件等待的线程间的同步问题。举个例子：消费者和生产者问题。消费者与生产者最基本的关系是服务与被服务的关系，但是在线程同步与互斥中强调..
分类：
编程语言 时间：
2016-04-25 22:52:47
阅读次数：
315
二、生产者消费者模式的学生类成员变量生产与消费demo， @Version2.0 在学生类中添加同步方法：synchronized get（）消费者，synchronized set（）生产者 最终版的代码中： 把student的成员变量给私有化了， 把设置和获取的功能给封装成了功能，并加了同步， ...
分类：
编程语言 时间：
2016-04-25 21:01:07
阅读次数：
178
