iframe-proxy | Sunbelt Computer Software

History

47 lines (35 loc) · 872 Bytes

Raw

#!/usr/bin/env python

# -*- encoding: utf-8 -*-

"""

Topic: 使用队列的线程示例

Desc :

"""

import threading

from queue import Queue

__author__ = 'Xiong Neng'

class WorkerThread(threading.Thread):

def __init__(self, *args, **kwargs):

threading.Thread.__init__(self, *args, **kwargs)

self.inputq = Queue()

def send(self, item):

self.inputq.put(item)

def close(self):

self.inputq.put(None)

self.inputq.join()

def run(self):

while True:

item = self.inputq.get()

if not item:

break

print(item, end=',')

self.inputq.task_done()

return

def demo():

w = WorkerThread()

w.start()

w.send('hello test ')

w.send('world')

w.close()

if __name__ == '__main__':

demo()

Sunbelt Computer Software

PL/B Language Development and Support

Navigation Menu

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

threadqueue.py

Latest commit

History

threadqueue.py

File metadata and controls