如何在 Python 中运行脚本 18 小时?

Question

if __name__=='__main__':
print("================================================= n")
print 'The test will be running for: 18 hours ...'
get_current_time = datetime.now()
test_ended_time = get_current_time + timedelta(hours=18)
print 'Current time is:', get_current_time.time(), 'Your test will be ended at:', test_ended_time.time()
autodb = autodb_connect()
db = bw_dj_connect()
started_date, full_path, ips = main()

pid = os.getpid()
print('Main Process is started and PID is: ' + str(pid))
start_time = time.time()
process_list = []
for ip in ips:
p = Process(target=worker, args=(ip, started_date, full_path))
p.start()
p.join()
child_pid = str(p.pid)
print('PID is:' + child_pid)
process_list.append(child_pid)
child = multiprocessing.active_children()
print process_list
while child != []:
time.sleep(1)
child = multiprocessing.active_children()

print ' All processes are completed successfully ...'
print '_____________________________________'
print(' All processes took {} second!'.format(time.time()-start_time))

我有一个python测试脚本，它应该运行18个小时，然后杀死自己。该脚本对多设备使用多处理。我从main()函数获得的数据将随着时间的推移而改变。

我在多处理中将这三个参数传递给工人方法。

我怎样才能做到这一点？

Answer 1

如果你不需要过多地担心清理子进程，你可以使用.terminate()杀死它们

...
time.sleep(18 * 60 * 60) # go to sleep for 18 hours
children = multiprocessing.active_children()
for child in children:
child.terminate()
for child in multiprocessing.active_children():
child.join() # wait for the children to terminate

如果您确实需要在所有子进程中进行一些清理，那么您需要修改它们的运行循环(我假设while True)以监视时间流逝，并且仅在主程序中具有上面的第二个while循环，等待子进程自行离开。

Answer 2

你永远不会将datetime.now()与test_ended_time进行比较。

# check if my current time is greater than the 18 hour check point.
While datetime.now() < test_ended_time and multiprocessing.active_children():
print('still running my process.')
sys.exit(0)