Board logo

标题: [原创代码] 解决Python多进程input 报EOF错误! 增加一个多线程类 [打印本页]

作者: Gin_Q    时间: 2020-8-5 16:11     标题: 解决Python多进程input 报EOF错误! 增加一个多线程类

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





欢迎光临 批处理之家 (http://bbs.bathome.net/) Powered by Discuz! 7.2