在阻塞模式下，在I/O操作完成前，执行的操作函数将一直等候而不会立即返回，该函数所在的线程会阻塞在这里。相反，在非阻塞模式下，套接字函数立即返回，而不管I/O是否完成。 #生产者和消费者模式 ## 服务器端的简化形式（#这套流程需要完全背诵#） #完整代码# ...
queue队列 当必须安全地在多个线程之间交换信息时，队列在线程编程中特别有用。 没有数据会一直等。服务器端就会卡住。 有数据就取没有数据就抛出异常。 block=true 阻塞 取不到数据就会阻塞IO timeout =1 阻塞时间1S 等待一秒 没有新消息就抛出错误 maxsize= 3 队列只 ...
分类：
编程语言 时间：
2017-10-18 09:58:25
阅读次数：
163
【BlockingQueue常见】 [ ArrayBlockingQueue ] 基于数组的阻塞队列的实现，在ArrayBlockingQueue内部，维护了一个定长数组，以便缓存队列中的数据对象，其内部没实现读写分离，也就意味着生产者和消费者不能完全并行，长度需要自定义，可以指定先进先出或者先进后 ...
分类：
其他好文 时间：
2017-10-14 18:33:16
阅读次数：
165
Apache Kafka 是什么？ Kafka 是一个开源的分布式流处理平台，其简化了不同数据系统的集成。流指的是一个数据管道，应用能够通过流不断地接收数据。Kafka 作为流处理系统主要有两个用处： 相比于其它技术，Kafka 拥有更高的吞吐量，内置分区，副本和容错率。这些使得 Kafka 成为大 ...
分类：
编程语言 时间：
2017-10-12 14:35:28
阅读次数：
860
小故事：Disruptor说的是生产者和消费者的故事. 有一个数组.生产者往里面扔芝麻.消费者从里面捡芝麻. 但是扔芝麻和捡芝麻也要考虑速度的问题. 1 消费者捡的比扔的快 那么消费者要停下来.生产者扔了新的芝麻,然后消费者继续. 2 数组的长度是有限的,生产者到末尾的时候会再从数组的开始位置继续. ...
分类：
编程语言 时间：
2017-10-12 12:14:39
阅读次数：
247
礼悟： 好好学习多思考，尊师重道存感恩。叶见寻根三返一，活水清源藏于零。 虚怀若谷良心主，皓月当空自在王。愿给最苦行无悔，诚劝且行且珍惜。 资源类： 锁类： 生产者类： 消费者类： 测试类： 运行结果： 感想： 多线程这里确实难，给最苦 虽然跟着视频教程写出了代码，但是 过几天再看的时候，就又迷糊了 ...
分类：
编程语言 时间：
2017-10-08 22:27:43
阅读次数：
249
消息队列由生产者和消费者共同协作，生产者产生消息放入队列中，消费者从队列中取出消息。 ...
分类：
其他好文 时间：
2017-10-08 14:44:22
阅读次数：
218
关于消息的发布与订阅，之前一直使用的是activeMQ基于JMS的消息队列进行操作的，最近听说有一个更高效的消息的发布与订阅技术，就是Kafka。 关于kafka的介绍，在这里就不做过多讲解了，因为我自己也不是很了解，大概就知道它与activeMQ一样，都是具有生产者和消费者的发布与订阅消息的机制。... ...
分类：
其他好文 时间：
2017-10-03 12:07:01
阅读次数：
4970
前言： 生产者和消费者模式是我们在学习多线程中很经典的一个模式，它主要分为生产者和消费者，分别是两个线程， 目录 一：生产者和消费者模式简介 二：生产者和消费者模式的实现 声明：本例来源于java经典著作：《Think in java》，接下来将会采用本例子将会借鉴其中的案例进行分析 首先我们来设想 ...
分类：
编程语言 时间：
2017-10-03 00:52:37
阅读次数：
394
生产者和消费者不能同时进行，这里要注意没有实现读写分离，是有界的阻塞的队列，可以用来实现生产者和消费者模式 我们来看下面的代码： 程序运行的结果是： Exception in thread "main" java.lang.IllegalStateException: Queue full at j ...
分类：
编程语言 时间：
2017-09-30 17:49:16
阅读次数：
283
