1.自定義線程池

import threadingimport Queueimport time queue = Queue.Queue()  def put_data_in_queue():  for i in xrange(10):    queue.put(i)  class MyThread(threading.Thread):  def run(self):    while not queue.empty():      sleep_times = queue.get()      time.sleep(sleep_times)      queue.task_done()  def main_function():  threads_num = 6  while True:    put_data_in_queue()    for i in xrange(threads_num):      myThread = MyThread()      myThread.setDaemon(True)      myThread.start()    queue.join()    time.sleep(60)

2.多線程與signal信號(hào)的監(jiān)控結(jié)合

import threadingimport Queueimport timeimport signal queue = Queue.Queue()stop = False  def receive_signal(signum, stack):  signal.signal(signal.SIGTERM, original_sigterm)  global stop  stop = True  def put_data_in_queue():  for i in xrange(10):    queue.put(i)  class MyThread(threading.Thread):  def run(self):    while not queue.empty():      sleep_times = queue.get()      time.sleep(sleep_times)      queue.task_done()  def main_function():  threads_num = 6  while not stop:    put_data_in_queue()    for i in xrange(threads_num):      myThread = MyThread()      myThread.setDaemon(True)      myThread.start()    queue.join()    time.sleep(60)  if __name__ == "__main__":  original_sigterm = signal.getsignal(signal.SIGTERM)  signal.signal(signal.SIGTERM, receive_signal)  main_function()

以上這篇python自定義線程池控制線程數(shù)量的示例就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持武林站長(zhǎng)站。