64 lines
1.4 KiB
Python
64 lines
1.4 KiB
Python
|
import threading
|
|||
|
|
import multiprocessing as mp
|
|||
|
|
from multiprocessing import Queue
|
|||
|
|
#from queue import Queue #Thread 無法回傳值，所以要使用 Queue.put() 將要傳回的值存入 Queue，再用 Queue.get() 取出
|
|||
|
|
import time
|
|||
|
|
import os
|
|||
|
|
import datetime
|
|||
|
|
import logging
|
|||
|
|
import cv2
|
|||
|
|
from Process_class import Process_class
|
|||
|
|
from Thread_class import Thread_class
|
|||
|
|
|
|||
|
|
log_file = f'LOG.txt'
|
|||
|
|
# create logger
|
|||
|
|
logger = logging.getLogger(log_file)
|
|||
|
|
logger.setLevel(logging.DEBUG)
|
|||
|
|
|
|||
|
|
# create console handler and set level to debug
|
|||
|
|
ch = logging.StreamHandler()
|
|||
|
|
ch.setLevel(logging.DEBUG)
|
|||
|
|
|
|||
|
|
# create file handler and set level to info
|
|||
|
|
fh = logging.FileHandler(log_file)
|
|||
|
|
fh.setLevel(logging.INFO)
|
|||
|
|
|
|||
|
|
# create formatter
|
|||
|
|
formatter = logging.Formatter(
|
|||
|
|
'%(asctime)s - %(name)-36s - %(levelname)-8s - %(message)s')
|
|||
|
|
|
|||
|
|
# add formatter to console handler and file handler
|
|||
|
|
ch.setFormatter(formatter)
|
|||
|
|
fh.setFormatter(formatter)
|
|||
|
|
|
|||
|
|
# add console handler and file handler to logger
|
|||
|
|
logger.addHandler(ch)
|
|||
|
|
logger.addHandler(fh)
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
if __name__=='__main__':
|
|||
|
|
q = Queue()
|
|||
|
|
name_list = ["A", "B", "C", "D"]
|
|||
|
|
process_list = []
|
|||
|
|
for i in range(0, len(name_list)):
|
|||
|
|
process_list.append(Thread_class(name_list[i],q))
|
|||
|
|
for i in range(0, len(process_list)):
|
|||
|
|
process_list[i].start()
|
|||
|
|
for i in range(0, len(process_list)):
|
|||
|
|
process_list[i].join()
|
|||
|
|
|
|||
|
|
for i in range(0, len(process_list)):
|
|||
|
|
#print(q.get())
|
|||
|
|
print(process_list[i].test_return())
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|