python多进程 队列关闭

      # !/usr/bin/env python
      # -*- coding: utf-8 -*-
      import multiprocessing
      import random
      import time
      import os
      import cv2
      class producer(multiprocessing.Process):
      def __init__(self, queue):
       multiprocessing.Process.__init__(self)
       self.queue = queue
      def run(self):
       print("process",self.queue)
       path = r"D:\cam2pick_jiance\pic_0513_1\JPEGImages/"
       files = os.listdir(path)
       images = []
      for j, file in enumerate(files):
       img = cv2.imread(path + file)
      if img is None:
      continue
      if j > 100:
      break
       images.append(img)
      for i in range(60000):
      for j in range(len(images) - 1):
       self.queue.put((images[j], j))
       print("put",self.pid)
       time.sleep(0.5)
       print("The size of queue is %s"
  
 

文章来源: blog.csdn.net，作者：网奇，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/jacke121/article/details/91860183