#!/usr/bin/env python# -*- coding:utf-8 -*-# yield x相当于return 控制的是函数的返回值# 在定义生成器函数的yield时，可以给yield赋值# x = yield的另一个特性，接收send传过来的值，赋给x# send类似于__next__ ...
分类：
编程语言 时间：
2018-10-04 10:31:10
阅读次数：
171
1、概念 所谓，生产者与消费者模型，本质上是把进程通信的问题分开考虑 生产者，只需要往队列里面丢东西（生产者不需要关心消费者） 消费者，只需要从队列里面拿东西（消费者也不需要关心生产者） 1 # 多线程实现生产者消费者模型 2 import threading 3 import random 4 i ...
分类：
其他好文 时间：
2018-10-04 09:22:21
阅读次数：
166
一、实现Filter接口 1、消费者过滤器:ConsumerTraceFilter.java 2、生产者过滤器:ProviderTraceFilter.java 二、配置SPI Filter扩展文件 1、生产者配置 在目录：resources/META-INF/dubbo/ 创建com.alibab ...
分类：
其他好文 时间：
2018-10-03 23:51:48
阅读次数：
335
1.消息队列概述 可以理解为保存消息的一个媒介/或者是个容器，与之相关有两个概念（即生产者（Publish）与消费者（Consumer））。所谓生产者，就是生产创造消息的一方，那么，消费者便是从队列中取出消息，完成相应的某种目的。总而言之，消息队列是搭建生产者与消费者沟通的一座桥梁。 消息队列的产品 ...
分类：
其他好文 时间：
2018-10-02 17:43:27
阅读次数：
161
synchronized的功能扩展： 重入锁；ReentrantLock； 其实也就是lock对于synchronized的替代了，要注意的一个点就是你可以锁多个，但是你锁了几个，最后就要解锁几个这个问题； 使用lock.lock()加锁，使用lock.unlock()解锁； 提供中断处理； 使用中 ...
分类：
其他好文 时间：
2018-10-01 23:47:58
阅读次数：
325
一、配置文件 1、生产者配置provider.xml 2、消费者配置consumer.xml 3、主要配置分类 4、配置覆盖关系 以 timeout 为例，显示了配置的查找顺序，其它 retries, loadbalance, actives 等类似： 方法级优先，接口级次之，全局配置再次之。 如果 ...
分类：
其他好文 时间：
2018-10-01 19:07:56
阅读次数：
128
在最初状态下，生产者发送消息的时候 (1) 生产者连接到RabbitMQ Broker ， 建立一个连接( Connection) ，开启一个信道(Channel) (2) 生产者声明一个交换器，并设置相关属性，比如交换机类型、是否持久化等 (3) 生产者声明一个队列井设置相关属性，比如是否排他、是 ...
分类：
其他好文 时间：
2018-10-01 16:10:36
阅读次数：
187
RabbitMQ 整体上是一个生产者与消费者模型，主要负责接收、存储和转发消息。可以把消 息传递的过程想象成:当你将一个包裹送到邮局，邮局会暂存并最终将邮件通过邮递员送到收件人的手上， RabbitMQ 就好比由邮局、邮箱和邮递员组成的一个系统。从计算机术语层面来说，RabbitMQ 模型更像是一种 ...
分类：
其他好文 时间：
2018-10-01 15:02:59
阅读次数：
199
public class Test { public static void main(String[] args) { List list = new ArrayList(1); LockEntity lockEntity = new LockEntity(); new Thread(new PT... ...
分类：
编程语言 时间：
2018-09-30 16:39:40
阅读次数：
164
1、队列的介绍 进程彼此之间互相隔离，要实现进程间通信（IPC），multiprocessing模块支持两种形式：队列和管道，这两种方式都是使用消息传递的 创建队列的类（底层就是以管道和锁定的方式实现）： Queue([maxsize]):创建共享的进程队列，Queue是多进程安全的队列，可以使用Q ...
分类：
其他好文 时间：
2018-09-30 16:31:40
阅读次数：
185
