python自定义线程池控制线程数量的示例_Python

python自定义线程池控制线程数量的示例

2021-06-01 00:06AdgerZhou Python

今天小编就为大家分享一篇python自定义线程池控制线程数量的示例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

1.自定义线程池

				?

									import threading

									import Queue

									import 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信号的监控结合

				?

									import threading

									import Queue

									import time

									import 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()