利用multiprocessing ,threading,queue来多进程,多线程读取数据。
多进程
from multiprocessing import Process
for i in range(16):
t = Process(target = target)
t.start()
from multiprocessing import Queue
queue = Queue()
多线程
import threading
#import Queue
#queue = Queue.Queue()
class myThread(threading.Thread):
def __init__(self,arg):
threading.Thread.__init__(self)
self.arg = arg
def run(self):
generator(self.arg)
设置queue是为了拿到函数的返回值