码迷,mamicode.com
首页 > 编程语言 > 详细

Python简单线程间通信

时间:2017-09-23 23:30:46      阅读:61      评论:0      收藏:0      [点我收藏+]

标签:start   保存   queue   sid   threading   安全   port   logs   mat   

本节主要举一个简单的线程间通信的例子,利用线程安全的数据结构queue.Queue保存线程间通信的内容,

import queue
from threading import Thread
from random import randint


class WriteThread(Thread):
    def __init__(self,sid,queue):
        Thread.__init__(self)
        self.sid = sid
        self.queue = queue
    def run(self):
        data = [randint(1,10) for _ in range(0,5)]
        self.queue.put((self.sid,data)) #--> 这里要主要,把线程号和data放在一起 作为一个元组输入到queue中,否则就会提示整数不是一个迭代对象

class ReadThread(Thread):
    def __init__(self,queue):
        Thread.__init__(self)
        self.queue = queue
    def run(self):
        while True:
            sid, data  = self.queue.get()
            print("Data read from thread {0},data is {1}".format(sid,data))

q= queue.Queue()
WThread = [WriteThread(i, q) for i in range(0,5)]
RThread = ReadThread(q)

for t in WThread:
    t.start()
RThread.start()

 

Python简单线程间通信

标签:start   保存   queue   sid   threading   安全   port   logs   mat   

(0)
(0)
   
举报
评论 一句话评论(0
0条  
登录后才能评论!
© 2014 mamicode.com 版权所有 京ICP备13008772号-2
迷上了代码!