#!/usr/bin/python
from Queue import Queue
from Queue import PriorityQueue
a1=‘a1‘
a2=‘a2‘
a3=‘a3‘
a4=‘a4‘
a5=‘a5‘b1=‘b1‘
b2=‘b2‘
b3=‘b3‘
b4=‘b4‘
b5=‘b5‘q = Queue()
pq = PriorityQueue()
for i in xrange(5):p = 5 - iq.put("a"+str(p))q.put("b"+str(p))pq.put((p,"a"+str(p)))pq.put((p,"b"+str(p)))for i in xrange(5):p = 5 - iq.put("a"+str(p)+str(i+5))q.put("b"+str(p)+str(i+5))pq.put((p...
和开源软件MQ 很相似 先进先出的逻辑，一个，N个噻， 1个，N个听Q from multiprocessing import Process,Queue#队列,先进先出q=Queue(3)q.put({‘a‘:1})q.put(‘b‘)q.put(‘c‘)print(q.full()) -->是否 噻满q.put(‘d‘,False) #等同于q.put_nowait(‘d‘) 塞满后 再 噻，不 等待，直接报错q.put(‘d‘,timeout=2) #塞满后 再噻 等待2秒， 不能噻就报错print(q.qsize()) #查看q中 值的个数print(q.get())print(q.get())pri...
1.队列(queue)用法：import queue
q = queue.Queue() #先进先出模式
q.put(1) #存放数据在q里 作用: 1）解耦 2)提高效率class queue.Queue(maxsize=0) #先入先出class queue.LifoQueue(maxsize=0) #后进先出 class queue.PriorityQueue(maxsize=0) #存储数据时可设置优先级的队列Queue.qsize() ...
一、线程Threading用于提供线程相关的操作，线程是应用程序中工作的最小单元。#!/usr/bin/env python
# -*- coding:utf-8 -*-import threading
import timedef show(arg):time.sleep(1)print‘thread‘+str(arg)for i in range(10):t = threading.Thread(target=show, args=(i,))t.start()print‘main thread stop‘上述代码创建了10个“前台”线程，然后控制器就交给了CPU，CPU根据指定算法进行调度，分片执行指令。更多方法：sta...
结合redis 队列 做了一个例子#!/usr/bin/env python
# coding: utf-8
# @Time : 2018/12/21 0021 13:57
# @Site :
# @File : demos.py
# @Software: PyCharm
import MySQLdb
import redis
import json
import os, time
import threading
from multiprocessing import Pool, Process
import os, time, random
import sysreload(sys)
sys.setdefaultencoding(‘utf8‘)class InsertData():def __init__(self):# 去掉一些无...
1. 信号量 对于多进程来说，多个进程同时修改数据，就可能出现安全隐患，所以引入了锁，这一机制，但锁只能有一把来控制一个的开关，当你需要几把锁的时候，就可能用到信号量的概念。他是用了锁的原理，内置了一个计数器，在同一时内，只能有指定数量的进程来执行某一段被控制的代码。import time,random
from multiprocessing import Process,Semaphoredef singing(i,sem):‘‘‘:param i: 随机生成20个数的值:param sem:生...
1.栈结构，其实就是一个后进先出的一个线性表，只能在栈顶压入或弹出元素。用列表表示栈，则向栈中压入元素，可以用列表的append()方法来实现，弹出栈顶元素可以用列表的pop()方法实现。 1 >>> x=[] #创建一个空列表，此处表示栈 2 >>> x3[]4 >>> x.append(‘a‘) #压入元素‘a‘ 5 >>> x6 [‘a‘]7 >>> x.append(‘b‘) #压入元素‘b‘ 8 >>> x9 [‘a‘, ‘b‘]
10 >>> x.pop() #弹出栈顶元素‘b‘11‘b‘...
import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters(‘localhost‘))
channel = connection.channel()#声明queue
channel.queue_declare(queue=‘hello‘)# RabbitMQ a message can never be sent directly to the queue, it always needs to go through an exchange.
channel.basic_publish(exchange=‘‘,routing_key=‘hello‘,body=‘Hello World!‘)
print(" [x] Sent ‘Hello World!‘")
connectio...
首先来描述下环境，在机器上有很多个JAVA程序，我们在每个JAVA程序里都配置了一个启动|停止|重启的脚本举个例子：我们现在要同时运行这些脚本，来达到快速启动所有的JAVA程序，如果我们只用多线程的话，线程是不会返回消息给父进程，我们如何才能知道这些程序是启动成功了呢？所以我们用到了队列来管理。"""我试过gevent,但是会在command这里造成阻塞"""gevent代码如下 如果有朋友知道如何优化，请您告诉我#!/usr/bin/python2.7
#...
import time
from multiprocessing import Process,Queue#生产者def producer(q):for i in range(10):time.sleep(0.7)s = ‘大包子%s号‘%iprint(s+‘新鲜出炉,拿去用‘)q.put(s)def consumer(q):while 1:time.sleep(1)baozi = q.get()print(baozi+‘被吃了‘)if__name__ == ‘__main__‘:q = Queue(10)pro_p = Process(target=producer,args=(q,))con_p = Process(target=consumer,args=(q,))pro_p.start()con_p.start() 原文：ht...
一、互斥锁： 1.线程同步能够保证多个线程安全访问竞争资源，最简单的同步机制是引入互斥锁。 2.互斥锁为资源引入一个状态：锁定、非锁定 3.某个线程要更改共享数据是，先将其锁定。此时资源的状态为锁定，其他线程不能更改知道该线程释放资源，将资源的状态编程"非锁定"，其他的线程才能再次锁定该资源 4.互斥锁保证了每次只有一个线程进行写入操作，从而保证了多线程情况下数据的正确性。例子： 创建锁 suo = threading.LOc...
消息中间件 --->就是消息队列异步方式：不需要立马得到结果，需要排队同步方式：需要实时获得数据，坚决不能排队例子：#多进程模块multiprocessingfrom multiprocessing import Processfrom multiprocessing import Queuedef write(q): for i in ["a", "b", "c", "d"]: q.put(i) print ("put {0} to queue".format(i)) def read(q): while 1: result = q.get() print ("get {0} from queue".for...
标准库：一些最爱集合、堆和双端队列集合集合Set类位于sets模块中。>>> range(10)[0, 1, 2, 3, 4, 5, 6, 7, 8, 9]>>> set(range(10))set([0, 1, 2, 3, 4, 5, 6, 7, 8, 9]) 集合是由序列（或其他可迭代的对象)构建的。主要用于检查成员资格，因此，副本是被忽略的：>>> range(10)*2[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9]>>> set(range(10)*2)set([0, 1, 2, 3, 4, 5, 6, 7, 8, 9]) 和字典一样，集合元素的顺...
#!/usr/bin/python
# -*- coding: utf-8 -*-'''
Created on 2015-2-6
@author: beyondzhou
@name: test_bpriorityqueue.py
'''def test_bpriorityqueue():# import pyListQueuefrom myqueue import BPriorityQueueprint '#Init a queue named smith using enqueue'smith = BPriorityQueue(6)smith.enqueue('purple', 5)smith.enqueue('black', 1)smith.enqueue('orange', 3)smith.enqueue('white', 0)smith.enqueue('green', 1)sm...
一、什么是生产者消费者模型？生产者就是生产数据的线程，消费者指的就是消费数据的线程。在多线程开发过程中，生产者的速度比消费者的速度快，那么生产者就必须等待消费者把数据处理完，生产者才会产生新的数据，相对的，如果消费者处理数据的速度大于生产者，那么消费者就必须等待生产者。为了解决这种问题，就有了生产者消费者模型。生产者与消费者模型，是通过一个容器，来解决生产者和消费者之间的耦合性问题，生产者和消费者...