查看 KeyboardInterrupt 以退出多线程脚本后,我想知道是否可以使用键盘上的向上和向下键来增加/减少正在使用的线程数?这有望以与 KeyboardInterrupt 相同的方式发生,以便它可以随时发生。这样的事情是否可能,或者是否有另一种更适合这种情况的方法?
def do_something(input_file, threads):
concurrent = threads
l = read_csv(input_file)
for i in range(concurrent):
t = Thread(target=create_accounts)
t.daemon = True
t.start()
try:
for account in l:
q.put(account)
q.join()
except KeyboardInterrupt:
sys.exit(1)
if __name__ == '__main__':
threads = 1
q = Queue(threads * 2)
do_something('test.csv', threads)