我有一个脚本需要运行 10 个小时。每一小时,我想休息 30 秒并继续该过程,直到测试时间完成。
def worker_1(ip, ask_time):
time_out = time.time() + ask_time*60*60
photo_directory = os.listdir(photo_path)
while time.time() < time_out:
take_break = time.time() + 60*60
while time.time() <= take_break:
#Send command to device
if time.time() == take_break:
action = 'DoAction'
arg_list = []
arg_list.append(upnp_path)
arg_list.append(' --action=')
arg_list.append(action)
arg_list.append(' --ip=')
arg_list.append('34.35.35.02')
x = subprocess.Popen(arg_list, shell=True)
subprocess.call(["python" , arg_list])
break
print "Sleep time 30 secs ..."
else:
for photo in photo_directory:
choice_photos_list = list()
image_name = ["john", "Sue", "lee"]
random_choice = random.choice(image_name)
if photo.lower().startswith(random_choice):
choice_photos_list.append(photo)
for choice_photo in choice_photos_list:
action = 'CancelAction'
arg_list = []
arg_list.append(upnp_path)
arg_list.append(' --action=')
arg_list.append(action)
arg_list.append(' --ip=')
arg_list.append('34.35.35.02')
arg_list.append(' --img=')
arg_list.append(choice_photo)
x = subprocess.Popen(arg_list, shell=True)
subprocess.call(["python" , arg_list])
time.sleep(30)
子进程在总时间完成后结束。但它确实每隔一小时休息一次。任何想法将不胜感激。
def worker_1():
import time
Minute, Hourcount, Match = int(time.strftime("%M")), 0, time.strftime("%S")
while Hourcount < 10:
#Do Something
if int(time.strftime("%M")) == Minute:
if Match == time.strftime("%S"):
time.sleep(30)
Hourcount += 1
Match = time.strftime("%S")
我复制并添加了我曾经写过的一些代码。以此为基础,并根据您的特定需求进行构建。