#coding:utf-8
import random
from time import sleep
import sys
import multiprocessing
import os
#
#需求分析：有大批量數(shù)據(jù)需要執(zhí)行，而且是重復(fù)一個(gè)函數(shù)操作（例如爆破密碼），如果全部開(kāi)始線程數(shù)N多，這里控制住線程數(shù)m個(gè)并行執(zhí)行，其他等待
#
lock=multiprocessing.Lock()#一個(gè)鎖
def a(x):#模擬需要重復(fù)執(zhí)行的函數(shù)
  lock.acquire()#輸出時(shí)候上鎖，否則進(jìn)程同時(shí)輸出時(shí)候會(huì)混亂，不可讀
  print '開(kāi)始進(jìn)程：',os.getpid(),'模擬進(jìn)程時(shí)間:',x
  lock.release()
  
  sleep(x)#模擬執(zhí)行操作
  
  lock.acquire()
  print '結(jié)束進(jìn)程：',os.getpid(),'預(yù)測(cè)下一個(gè)進(jìn)程啟動(dòng)會(huì)使用該進(jìn)程號(hào)'
  lock.release()
list=[]
for i in range(10):#產(chǎn)生一個(gè)隨機(jī)數(shù)數(shù)組，模擬每次調(diào)用函數(shù)需要的輸入，這里模擬總共有10組需要處理
  list.append(random.randint(1,10))
  
pool=multiprocessing.Pool(processes=3)#限制并行進(jìn)程數(shù)為3
pool.map(a,list)#創(chuàng)建進(jìn)程池，調(diào)用函數(shù)a，傳入?yún)?shù)為list,此參數(shù)必須是一個(gè)可迭代對(duì)象,因?yàn)閙ap是在迭代創(chuàng)建每個(gè)進(jìn)程

#coding:utf-8
import threading
import random
import Queue
from time import sleep
import sys
#
#需求分析：有大批量數(shù)據(jù)需要執(zhí)行，而且是重復(fù)一個(gè)函數(shù)操作（例如爆破密碼），如果全部開(kāi)始線程數(shù)N多，這里控制住線程數(shù)m個(gè)并行執(zhí)行，其他等待
#
#繼承一個(gè)Thread類(lèi)，在run方法中進(jìn)行需要重復(fù)的單個(gè)函數(shù)操作
class Test(threading.Thread):
  def __init__(self,queue,lock,num):
    #傳遞一個(gè)隊(duì)列queue和線程鎖，并行數(shù)
    threading.Thread.__init__(self)
    self.queue=queue
    self.lock=lock
    self.num=num
  def run(self):
    #while True:#不使用threading.Semaphore，直接開(kāi)始所有線程，程序執(zhí)行完畢線程都還不死，最后的print threading.enumerate()可以看出
    with self.num:#同時(shí)并行指定的線程數(shù)量，執(zhí)行完畢一個(gè)則死掉一個(gè)線程
      #以下為需要重復(fù)的單次函數(shù)操作
      n=self.queue.get()#等待隊(duì)列進(jìn)入
      lock.acquire()#鎖住線程，防止同時(shí)輸出造成混亂
      print '開(kāi)始一個(gè)線程：',self.name,'模擬的執(zhí)行時(shí)間：',n
      print '隊(duì)列剩余：',queue.qsize()
      print threading.enumerate()
      lock.release()
      sleep(n)#執(zhí)行單次操作，這里sleep模擬執(zhí)行過(guò)程
      self.queue.task_done()#發(fā)出此隊(duì)列完成信號(hào)
threads=[]
queue=Queue.Queue()
lock=threading.Lock()
num=threading.Semaphore(3)#設(shè)置同時(shí)執(zhí)行的線程數(shù)為3，其他等待執(zhí)行
#啟動(dòng)所有線程
for i in range(10):#總共需要執(zhí)行的次數(shù)
  t=Test(queue,lock,num)
  t.start()
  threads.append(t)
  #吧隊(duì)列傳入線程，是run結(jié)束等待開(kāi)始執(zhí)行，放下面單獨(dú)一個(gè)for也行，這里少個(gè)循環(huán)吧
  n=random.randint(1,10)
  queue.put(n)#模擬執(zhí)行函數(shù)的逐個(gè)不同輸入
#吧隊(duì)列傳入線程，是run結(jié)束等待開(kāi)始執(zhí)行
#for t in threads:
#  n=random.randint(1,10)
#  queue.put(n)
#等待線程執(zhí)行完畢
for t in threads:
  t.join()
queue.join()#等待隊(duì)列執(zhí)行完畢才繼續(xù)執(zhí)行，否則下面語(yǔ)句會(huì)在線程未接受就開(kāi)始執(zhí)行
print '所有執(zhí)行完畢'
print threading.active_count()
print threading.enumerate()