yuzhibott 最近的时间轴更新 yuzhibott 最近的时间轴更新 |
yuzhibottV2EX 第 249367 号会员，加入于 2017-08-18 09:26:34 +08:00 |
| fps 游戏中外挂和反挂用到的技术是什么
1 分享发现 • yuzhibott • 2018-03-25 15:18:47 PM • 最后回复来自 m939594960
|
18 |
| 在异步进程下创建线程，线程执行循环任务，为什么线程还没执行完任务进程就退出了？ Python • yuzhibott • 2017-09-27 14:03:54 PM • 最后回复来自 petelin | 13 |
yuzhibott 最近回复了
2019-03-27 16:58:05 +08:00 回复了 ucmp0001 创建的主题 › 分享发现 › 迫于经济形势不好，想建一个通过技术手段赚外快撸羊毛的信息交流群，币圈也好，爬虫也罢，目的是资源共享 |
@lesmiserables0 不能这么骗别人的 23333
2017-09-25 17:59:57 +08:00 回复了 yuzhibott 创建的主题 › Python › 在异步进程下创建线程，线程执行循环任务，为什么线程还没执行完任务进程就退出了？ |
@shibingsw 多个定时任务啊，每个定时不一样，join 不是只能一个一个线程执行么
2017-09-25 17:50:27 +08:00 回复了 yuzhibott 创建的主题 › Python › 在异步进程下创建线程，线程执行循环任务，为什么线程还没执行完任务进程就退出了？ |
num = 0
def test1(*data):
global num
i = data[0]
while True:
if num == 10:
num = 0
break
print(i)
num += 1
time.sleep(2)
def test2(*data):
i = data[0]
threading.Thread(target=test1, args=(i,)).start()
print("done")
pool = multiprocessing.Pool(processes=5)
for j in range(2):
pool.apply_async(test2, (j,))
def test1(*data):
global num
i = data[0]
while True:
if num == 10:
num = 0
break
print(i)
num += 1
time.sleep(2)
def test2(*data):
i = data[0]
threading.Thread(target=test1, args=(i,)).start()
print("done")
pool = multiprocessing.Pool(processes=5)
for j in range(2):
pool.apply_async(test2, (j,))
2017-09-25 17:35:50 +08:00 回复了 yuzhibott 创建的主题 › Python › 在异步进程下创建线程，线程执行循环任务，为什么线程还没执行完任务进程就退出了？ |
大概代码如上，不能用 join()，因为实际中是多任务定时处理，每个任务时间不一样
2017-09-25 17:34:32 +08:00 回复了 yuzhibott 创建的主题 › Python › 在异步进程下创建线程，线程执行循环任务，为什么线程还没执行完任务进程就退出了？ |
num = 0
def test1(*data):
global num
i = data[0]
while True:
if num == 10:
num = 0
break
print(i)
num += 1
time.sleep(2)
def test2(*data):
i = data[0]
threading.Thread(target=test1, args=(i,)).start()
print("done")
pool = multiprocessing.Pool(processes=5)
for j in range(2):
pool.apply_async(test2, (j,))
def test1(*data):
global num
i = data[0]
while True:
if num == 10:
num = 0
break
print(i)
num += 1
time.sleep(2)
def test2(*data):
i = data[0]
threading.Thread(target=test1, args=(i,)).start()
print("done")
pool = multiprocessing.Pool(processes=5)
for j in range(2):
pool.apply_async(test2, (j,))
Select Language