-
Notifications
You must be signed in to change notification settings - Fork 0
/
multiproc.py
executable file
·52 lines (42 loc) · 1.41 KB
/
multiproc.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
import logging
import multiprocesshandlers
import time
import random
from multiprocessing import Process
from threading import Thread
def create_logger():
app_name = 'sistel-osc-socket'
log_file = app_name + '.log'
logger = logging.getLogger()
logger.setLevel(logging.INFO)
fh = multiprocesshandlers.TimedRotatingFileHandler(log_file, when='s', interval=10, backupCount=3)
fh.setLevel(logging.INFO)
ch = multiprocesshandlers.StreamHandler()
ch.setLevel(logging.INFO)
formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
fh.setFormatter(formatter)
ch.setFormatter(formatter)
logger.addHandler(fh)
logger.addHandler(ch)
return logger
def run_proc(proc_name, logger):
def run_thread(thread_name):
while True:
time.sleep(random.random() * 1)
logger.info('%s-%s: %s' % (proc_name, thread_name, time.strftime("%Y-%m-%d %H:%M:%S")))
threads = []
for i in range(0, 10):
t = Thread(target=run_thread, args=["Thread-%s" % i])
t.start()
threads.append(t)
for t in threads:
t.join()
if __name__ == '__main__':
logger = create_logger()
procs = []
for i in range(0, 10):
p = Process(target=run_proc, args=['Proc-%s' % i, logger])
p.start()
procs.append(p)
for p in procs:
p.join()