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