blog.zhuohua.store - Powered by Discuz! Board

#coding=utf-8
import _thread
from time import sleep
import datetime,os
def func1(lock):
dt = datetime.datetime.now()
tt = dt.strftime('%Y%m%d_%H%M%S')
Key_t ="\n\n检测时间：" + tt + "\n"
Path_1 = "/root/1.txt"
f_name = open(Path_1,'a') #写入（追加）具体检测时间到文件
f_name.write(Key_t)
f_name.close()
#调用Linux命令
os.system("ping blog.zhuohua.store -c 10 >> /root/1.txt")
sleep(120) #线程一休眠120秒；各个线程的休眠时间要保持一致
lock.release()
def func2(lock):
dt = datetime.datetime.now()
tt = dt.strftime('%Y%m%d_%H%M%S')
Key_t ="\n\n检测时间：" + tt + "\n"
Path_1 = "/root/2.log"
f_name = open(Path_1,'a')
f_name.write(Key_t)
f_name.close()
os.system("ping www.baidu.com -c 10 >> /root/2.log")
sleep(120) #线程二休眠120秒；各个线程的休眠时间要保持一致
lock.release()
def func_main():
fields_1 = range(0, 2) # "2" 意味着有2个线程，依此类推
fields_2 = []
for Key_1 in fields_1:
Key_1 = _thread.allocate_lock()
Key_1.acquire()
fields_2.append(Key_1)
# [0]、[1]代表线程号，依此类推；分别给每个函数的一个变量进行赋值
_thread.start_new_thread(func1,(fields_2[0],))
_thread.start_new_thread(func2,(fields_2[1],))
for i in fields_1:
while fields_2[i].locked():
pass
if __name__ == '__main__':
index_1 = 0
while index_1 < 3: #进程执行3次后自动结束
func_main()
index_1 = index_1 + 1

复制代码

#coding=utf-8
import _thread
from time import sleep
import datetime,os
def func1(n_sec,lock):
dt = datetime.datetime.now()
tt = dt.strftime('%Y%m%d_%H%M%S')
Key_t ="\n\n检测时间：" + tt + "\n"
Path_1 = "/root/1.txt"
f_name = open(Path_1,'a') #写入（追加）具体检测时间到文件
f_name.write(Key_t)
f_name.close()
#调用Linux命令
os.system("ping blog.zhuohua.store -c 10 >> /root/1.txt")
sleep(n_sec)
lock.release()
def func2(n_sec,lock):
dt = datetime.datetime.now()
tt = dt.strftime('%Y%m%d_%H%M%S')
Key_t ="\n\n检测时间：" + tt + "\n"
Path_1 = "/root/2.log"
f_name = open(Path_1,'a')
f_name.write(Key_t)
f_name.close()
os.system("ping www.baidu.com -c 10 >> /root/2.log")
sleep(n_sec)
lock.release()
def func3(n_sec,lock):
dt = datetime.datetime.now()
tt = dt.strftime('%Y%m%d_%H%M%S')
Key_t ="\n\n检测时间：" + tt + "\n"
Path_1 = "/root/3.log"
f_name = open(Path_1,'a')
f_name.write(Key_t)
f_name.close()
os.system("ping www.sina.com -c 10 >> /root/3.log")
sleep(n_sec)
lock.release()
def func_main():
fields_1 = range(0, 3) # "3" 意味着有3个线程，依此类推
fields_2 = []
for Key_1 in fields_1:
Key_1 = _thread.allocate_lock()
Key_1.acquire()
fields_2.append(Key_1)
# [0]、[1]、[2]代表线程号，依此类推；分别给每个函数的两个变量进行赋值
# 各个线程的休眠时间要保持一致
_thread.start_new_thread(func1,(60,fields_2[0])) #线程一休眠60秒
_thread.start_new_thread(func2,(60,fields_2[1])) #线程二休眠60秒
_thread.start_new_thread(func3,(60,fields_2[2])) #线程三休眠60秒
for i in fields_1:
while fields_2[i].locked():
pass
if __name__ == '__main__':
while True: #进程会无限次地自动执行下去
func_main()

复制代码