import logging
 from threading import Thread
 from queue import Queue
 from logging.handlers import QueueListener, QueueHandler
 from multiprocessing import Pool
 ?
 def setup_logging():
     # log的時(shí)候會(huì)寫到一個(gè)隊(duì)列里，然后有一個(gè)單獨(dú)的線程從這個(gè)隊(duì)列里去獲取日志信息并寫到文件里
     _log_queue = Queue()
     QueueListener(
         _log_queue, logging.FileHandler("out.log")).start()
     logging.getLogger().addHandler(QueueHandler(_log_queue))
 ?
     # 父進(jìn)程里起一個(gè)單獨(dú)的線程來(lái)寫日志
     def write_logs():
         while True:
             logging.info("hello, I just did something")
     Thread(target=write_logs).start()
 ?
 def runs_in_subprocess():
     print("About to log...")
     logging.info("hello, I did something")
     print("...logged")
 ?
 if __name__ == '__main__':
     setup_logging()
 ?
     # 讓一個(gè)進(jìn)程池在死循環(huán)里執(zhí)行，增加觸發(fā)死鎖的幾率
     while True:
         with Pool() as pool:
             pool.apply(runs_in_subprocess)

 About to log...
 ...logged
 About to log...
 ...logged
 About to log...

 from threading import Thread, enumerate
 from os import fork
 from time import sleep
 ?
 # Start a thread:
 Thread(target=lambda: sleep(60)).start()
 ?
 if fork():
     print("The parent process has {} threads".format(
         len(enumerate())))
 else:
     print("The child process has {} threads".format(
         len(enumerate())))

 import logging
 import multiprocessing
 from logging.handlers import QueueListener
 from time import sleep
 ?
 ?
 def listener_configurer():
     root = logging.getLogger()
     h = logging.handlers.RotatingFileHandler('out.log', 'a', 300, 10)
     f = logging.Formatter('%(asctime)s %(processName)-10s %(name)s %(levelname)-8s %(message)s')
     h.setFormatter(f)
     root.addHandler(h)
 ?
 # 從隊(duì)列獲取元素，并寫日志
 def listener_process(queue, configurer):
     configurer()
     while False:
         try:
             record = queue.get()
             if record is None:  
                 break
             logger = logging.getLogger(record.name)
             logger.handle(record) 
         except Exception:
             import sys, traceback
             print('Whoops! Problem:', file=sys.stderr)
             traceback.print_exc(file=sys.stderr)
 ?
 # 業(yè)務(wù)進(jìn)程的日志配置，使用queueHandler, 將要寫的日志塞入隊(duì)列
 def worker_configurer(queue):
     h = logging.handlers.QueueHandler(queue)  
     root = logging.getLogger()
     root.addHandler(h)
     root.setLevel(logging.DEBUG)
 ?
 ?
 def runs_in_subprocess(queue, configurer):
     configurer(queue)
     print("About to log...")
     logging.debug("hello, I did something: %s", multiprocessing.current_process().name)
     print("...logged, %s",queue.qsize())
 ?
 ?
 if __name__ == '__main__':
     queue = multiprocessing.Queue(-1)
     listener = multiprocessing.Process(target=listener_process,
                                        args=(queue, listener_configurer))
     listener.start()
     
     #父進(jìn)程也持續(xù)寫日志
     worker_configurer(queue)
     def write_logs():
         while True:
             logging.debug("in main process, I just did something")
     Thread(target=write_logs).start()
 ?
     while True:
         multiprocessing.Process(target=runs_in_subprocess,
                        args=(queue, worker_configurer)).start()
         sleep(2)
 ?

 if __name__ == '__main__':
     setup_logging()
 ?
     while True:
         # 使用spawn類型的啟動(dòng)
         with get_context("spawn").Pool() as pool:
             pool.apply(runs_in_subprocess)