python3 多线程接收用户输入类

Cool_Breeze

1. #coding=utf-8
   
2. '''
   
3. @ BY Cool_Breeze
   
4. @ 2020/08/06
   
5. @ 多线程接受用户输入
   
6. @ Rev 01
   
7. '''
   
8. 
   
9. 
   
10. from threading import Thread
    
11. from queue import Queue
    
12. import time
    
13. import os, sys
    
14. 
    
15. class input_wiat:
    
16.     '''
    
17.     @ string  提示字符串
    
18.     @ sec     等待时间 time.slee()
    
19.     @ fileno  IO文件描述
    
20.     '''
    
21.     def __init__(self, string, sec, fileno):
    
22.         self.string = string
    
23.         self.sec = sec
    
24.         self.fileno = fileno
    
25.         self.q = Queue()
    
26.         self.qb = Queue()
    
27.    
    
28.     def start(self):
    
29.         def f(q):
    
30.             while True:
    
31.                 try:
    
32.                     sys.stdin = os.fdopen(self.fileno)
    
33.                     n = int(input(self.string))
    
34.                     q.put(n)
    
35.                     break
    
36.                 except ValueError:
    
37.                     continue
    
38.         p = Thread(target=f, args=(self.q,))
    
39.         p.setDaemon(True)
    
40.         p.start()
    
41.    
    
42.     def wait(self):
    
43.         def f(qb):
    
44.             while True:
    
45.                 time.sleep(self.sec)
    
46.                 qb.put(True)
    
47. 
    
48.         p = Thread(target=f, args=(self.qb,))
    
49.         p.setDaemon(True)
    
50.         p.start()
    
51. 
    
52.     def result(self):
    
53.         self.wait()
    
54.         self.start()
    
55.         while True:
    
56.             if not self.q.empty():
    
57.                   return self.q.get()
    
58.             if not self.qb.empty():
    
59.                 return 0 #deflaut
    
60. 
    
61.    
    
62. if __name__ == '__main__':
    
63.     t = input_wiat('请输入：\n',5 , sys.stdin.fileno())
    
64.     print('返回结果 ：{}'.format(t.result()))

复制代码

Cool_Breeze

多进程

1. #coding=utf-8
   
2. 
   
3. from multiprocessing import Process,Queue
   
4. import time
   
5. import os, sys
   
6. 
   
7. q = Queue()
   
8. sec = 5
   
9. choose = 0
   
10. 
    
11. def input_wiat(q, fn):
    
12.     sys.stdin = os.fdopen(fn)
    
13.     while True:
    
14.         try:
    
15.             time.sleep(1)
    
16.             n = int(input('默请在5秒内输入一个整数\n默认为0\n请输入：'))
    
17.             q.put(n)
    
18.             break
    
19.         except ValueError:
    
20.             continue
    
21. 
    
22. if __name__ == '__main__':
    
23.     fn = sys.stdin.fileno()
    
24.     p = Process(target=input_wiat, args=(q, fn))
    
25.     p.start()
    
26.     while sec:
    
27.         if not q.empty():
    
28.             choose = q.get()
    
29.             break
    
30.         time.sleep(1)
    
31.         sec -= 1
    
32.     p.terminate()
    
33.     print('choose = {}'.format(choose))

复制代码