多线程开发可以更好的发挥多核cpu性能，常用的多线程设计模式有：Future、Master-Worker、Guard Susperionsion、不变、生产者-消费者 模式；jdk除了定义了若干并发的数据结构，也内置了多线程框架和各种线程池； 锁（分为内部锁、重入锁、读写锁）、ThreadLocal ...
分类：
编程语言 时间：
2019-01-15 14:00:41
阅读次数：
223
import time from multiprocessing import Process,Queue #生产者 def producer(q): for i in range(10): time.sleep(0.2) s = '大包子%s号'%i print(s+'新鲜出炉,拿去用') q.p... ...
分类：
编程语言 时间：
2019-01-14 16:34:46
阅读次数：
212
import time from multiprocessing import Process,Queue #生产者 def producer(q): for i in range(10): time.sleep(0.7) s = '大包子%s号'%i print(s+'新鲜出炉,拿去用') q.p... ...
分类：
编程语言 时间：
2019-01-14 16:30:31
阅读次数：
165
小编是菜鸟一枚，最近想试试MQ相关的技术，所以自己看了下RabbitMQ官网，试着写下自己的理解与操作的过程。 刚开始的第一篇，原理只介绍 生产者、消费者、队列，至于其他的内容，会在后续中陆续补齐。 引入MQ话题 什么时候会用到MQ 可能很多人有疑惑：MQ到底是什么？哪些场景下要使用MQ？前段时间安 ...
分类：
其他好文 时间：
2019-01-13 21:15:47
阅读次数：
383
上一篇文章介绍了：创建县城的两种方式、Event对象判断线程是否启动、利用信号量控制线程并发。 博客链接：线程、进程、协程和GIL（二） 这一篇来说说线程间通信的那些事儿： 一个线程向另一个线程发送数据最安全的方式就是使用queue库中的队列了，通过创建一个供多个线程共享的Queue对象，这些线程使 ...
分类：
编程语言 时间：
2019-01-13 01:56:03
阅读次数：
197
<! TOC "kafka" "安装" "修改配置文件" "java操作kafka" <! /TOC kafka kafka的操作相对来说简单很多 安装 修改配置文件 1. server.properties 2. 运行 java操作kafka 1. 依赖 2. 生产者 3. 消费者 ...
分类：
编程语言 时间：
2019-01-12 21:52:01
阅读次数：
294
上一篇博客 Android-Java多线程通讯(生产者 消费者)&等待唤醒机制 是两条线程（Thread-0 / Thread-1） 在被CPU随机切换执行； 而今天这篇博客是，在上一篇博客Android-Java多线程通讯(生产者 消费者)&等待唤醒机制 的基础上，扩大规模增加10条线程去执行 生 ...
分类：
移动开发 时间：
2019-01-09 15:45:29
阅读次数：
199
Kafka作为一个流式数据平台，对开发者提供了三种客户端：生产者/消费者、连接器、流处理。本文着重分析这三种客户端的线程模型。看到最后的通常都有惊喜。消费者的线程模型0.8版本以前的消费者客户端会创建一个基于ZK的消费者连接器，一个消费者客户端是一个Java进程，消费者可以订阅多个主题，每个主题也可以多个线程。为了让消息在多个节点被分布式地消费，提高消息处理的吞吐量，Kafka允许多个消费者订阅同
分类：
编程语言 时间：
2019-01-05 12:17:14
阅读次数：
226
同步异步 对于一次IO访问（以read举例），数据会先被拷贝到操作系统内核的缓冲区中，然后才会从操作系统内核的缓冲区拷贝到应用程序的地址空间。所以说，当一个read操作发生时，它会经历两个阶段： 1. 等待数据准备 (Waiting for the data to be ready) 2. 将数据从 ...
分类：
其他好文 时间：
2019-01-04 20:20:42
阅读次数：
189
RabbitMQ是一个在AMQP基础上完成的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。消息中间件的工作过程可以用生产者消费者模型来表示... ...
分类：
编程语言 时间：
2019-01-01 23:54:08
阅读次数：
230
