import multiprocessing

from time import ctime

def consumer(input_q):

    print("Into consumer:",ctime())

    while True:

        #处理项

        item = input_q.get()

        print("pull",item,"out of q")#此处替换为有用的工作

        input_q.task_done()#发出信号通知任务完成

    print("Out of consumer:",ctime()) #此句未执行，因为q.join()收集到四个task_done()信号后，主进程启动

def producer(sequence,output_q):

    print("Into producer:",ctime())

    for item in sequence:

        output_q.put(item)

        print("put",item,"into_q")

    print("Out of producer:",ctime())

#建立进程

if __name__ == "__main__":

    q=multiprocessing.JoinableQueue()

    #运行消费者进程

    cons_p = multiprocessing.Process(target=consumer,args=(q,))

    cons_p.daemon = True

    cons_p.start()

​

    #生产多个项，sequence代表要发送给消费者的项序列

    #在实践中，这可能是生成器的输出或通过一些其他方式生产出来的

    sequence = [1,2,3,4]

    producer(sequence,q)

    #等待所有项被处理

    q.join()

from collections import Iterable,Iterator

​

l = [i for i in range(5)]  #可迭代

print(isinstance(l,Iterable))#判断是否可迭代

print(isinstance(l,Iterator))#判断是否是一个迭代器

​

s_iter = iter(l)#将其转换为可以迭代的和迭代器

print(isinstance(s_iter,Iterable))#判断是否可迭代

print(isinstance(s_iter,Iterator))#判断是否是一个迭代器