利用 生产者 消费者 模型 复制 pcap 文件

     利用生产者消费者模型可以把需要多个循环、耦合过紧的程序架构改为一个松耦合的程序架构，这样就可以方便地在中间加入针对每一行处理代码，比如下面的情况，针对一个pcap,需要对每个包进行分析，下面的代码只是一个初步的框架，仅仅有一个复制的功能。

#!/bin/env python3
import sys,os
import threading
import time
import queue
import dpkt

tspkt=[]
def consume(thread_name, q):
    with open('./project3bak.pcap','wb') as pcapwr:
        writer=dpkt.pcap.Writer(pcapwr)
        while True:
            #time.sleep(2)
            product = q.get()
            print("%s consume %s" % (thread_name, product))
            writer.writepkt(pkt=product[1],ts=product[0])
def produce(thread_name, q):
        with open('./project3.pcap','rb') as pcaprd:
            reader=dpkt.pcap.Reader(pcaprd)
            for ts,pkt in reader.readpkts():
                tspkt=[ts,pkt]
                q.put(tspkt)
            
q = queue.Queue()
p = threading.Thread(target=produce, args=("producer",q))
c = threading.Thread(target=consume, args=("consumer",q))

p.start()
c.start()

p.join()