tensorflow中为了充分利用GPU，减少GPU等待数据的空闲时间，使用了两个线程分别执行数据读入和数据计算。 具体来说就是使用一个线程源源不断的将硬盘中的图片数据读入到一个内存队列中，另一个线程负责计算任务，所需数据直接从内存队列中获取。 tf在内存队列之前，还设立了一个文件名队列，文件名队列 ...
分类：
其他好文 时间：
2019-02-20 13:11:53
阅读次数：
2620
这里面因为属性都是private的，所以，其他的类中，使用只能是getBg，之类的，不能直接mqConfig.bg，这是不对的，因为不是静态成员。 但是 callBackProducerRetry 是静态成员，所以，可以直接访问，类名.callBackProducerRetry 请注意不是实例.ca ...
分类：
编程语言 时间：
2019-02-20 12:40:08
阅读次数：
146
在这一篇，我们将创建一个工作队列，将队列的消息让多个消费者来接收。一个消息对应一个消费者接收! 生产者 2个消费者 启动RabbitMQ服务 启动消费者Consumer1和Consumer2 启动生产者Producer 可以看到打印日志信息 生产者Producer P Sent 'Hello Wor ...
分类：
其他好文 时间：
2019-02-17 00:19:33
阅读次数：
263
在能够在windows下使用命令行启动kafka服务器，创建topic、producer、以及consumer后，尝试在JAVA中使用Kafka。 使用IDEA创建SpringBoot项目 这个使用IDEA创建一个新的SpringBoot项目就可以，也可以在https://start.spring. ...
分类：
编程语言 时间：
2019-02-15 22:26:25
阅读次数：
525
搭建kafka集群的基本环境需要安装JDK和zookeeper（或zookeeper集群） 下载kafaka安装包到服务器端并解压到指定目录 [root@hadoop01 soft]# wget https://www.apache.org/dyn/closer.cgi?path=/kafka/2.... ...
分类：
其他好文 时间：
2019-02-14 20:20:30
阅读次数：
166
在第一篇博客我们了解到一个kafka系统，通常是生产者Producer 将消息发送到 Broker，然后消费者 Consumer 去 Broker 获取，那么本篇博客我们来介绍什么是生产者Producer。 1、生产者概览 我们知道一个系统在运行过程中会有很多消息产生，比如前面说的对于一个购物网站， ...
分类：
其他好文 时间：
2019-02-11 16:51:21
阅读次数：
233
代码中,我们通常这样声明一个队列: 对于第5个参数: arguments , 它的类型是一个键值对集合 : 它到底有哪些key呢? 我们可以通过 RabbitMQ 的管理页面看到: 一共10个,鼠标点击"?",可以看到官方给出的解释. Message TTL 官方 : How long a mess ...
分类：
其他好文 时间：
2019-02-07 20:37:43
阅读次数：
272
package com.bfxy.rocketmq.model; import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.client.producer.DefaultMQPro ...
分类：
其他好文 时间：
2019-02-04 11:38:02
阅读次数：
200
网上有很多Kafka的测试文章，测试结果通常都是“吊打”其他MQ。感慨它的牛B之余我觉得必要仔细分析一下它如此快速的原因。这篇文章不同于其他介绍Kafka使用或者技术实现的文章，我会重点解释——为什么真快。（当然不是因为它用了Scala！！！！） 生产者（写入数据） 生产者（producer）是负责 ...
分类：
其他好文 时间：
2019-02-04 10:28:39
阅读次数：
162
```
import time
import queue
import threading q = queue.Queue() # 线程安全 def producer(id): """生产者""" while True: time.sleep(2) q.put('包子') print('厨师%s 生... ...
分类：
编程语言 时间：
2019-02-04 10:19:58
阅读次数：
139
