https://www.v2ex.com/t/524241#reply0
@simoncos

卧槽 我刚写了个类似的文章~

```
class CountdownTask:
def __init__(self):
self._running = True

def terminate(self):
self._running = False

def run(self, n):
while self._running and n > 0:
print('T-minus', n)
n -= 1
time.sleep(5)

c = CountdownTask()
t = Thread(target=c.run, args=(10,))
t.start()
c.terminate() # Signal termination
t.join() # Wait for actual termination (if needed)
```

t.daeman =true
老大做完，小弟就不做了

t.join()
老大等小弟做完继续在做


class CountdownTask:
def __init__(self):
self._running = True

def terminate(self):
self._running = False

def run(self, n):
while self._running and n > 0:
print('T-minus', n)
n -= 1
time.sleep(5)

c = CountdownTask()
t = multiprocessing.Process(target=c.run, args=(10,))
t.start()
c.terminate() # Signal termination
t.join() # Wait for actual termination (if needed)
老大给小弟给信号



不知道理解的对不对、、、

ipython manage.py shell

%debug

@liprais 不大么~

SEO：
深圳市成为智能交通系统有限公司 怎么样
深圳市成为智能交通系统有限公司 薪资待遇
深圳市成为智能交通系统有限公司 拖欠工资
深圳市成为智能交通系统有限公司 好不好
深圳市成为智能交通系统有限公司 无赖公司
深圳市成为智能交通系统有限公司 招聘信息
深圳市成为智能交通系统有限公司 信用怎么样
深圳市成为智能交通系统有限公司 企业架构
深圳市成为智能交通系统有限公司 公司氛围
深圳市成为智能交通系统有限公司 福利
深圳市成为智能交通系统有限公司 产品介绍
深圳市成为智能交通系统有限公司 企业咨询
深圳市成为智能交通系统有限公司 产品口碑

@zhoudaiyu 看了~我最近也要处理这个事情~

db.session.close()

每次都关掉，绝对会解决

和我想的差不多·~

http://musicforprogramming.net/?one 不谢

import asyncio

async def slow_operation(n):
await asyncio.sleep(n)
print('Slow operation {} complete'.format(n))
return n


loop = asyncio.get_event_loop()
done, _ = loop.run_until_complete(
asyncio.wait([
slow_operation(1),
slow_operation(2),
slow_operation(9),
slow_operation(2),
slow_operation(1),
slow_operation(2),
slow_operation(3),
]))
for fut in done:
print("return value is {}".format(fut.result()))

然后用 uvloop

y worker -A app.tasks.celery -l INFO -Q default -c 20 （每个队列多搞几个 worker ） -n default_worker.%%i

from time import sleep
from concurrent.futures import ThreadPoolExecutor\ ProcessPoolExecutor
def child_1():
sleep(9)
print(1)


def child_2():
sleep(2)
print(2)



def child_3():
sleep(3)
print(3)



def child_4():
sleep(1)
print(4)


def child_5():
sleep(2)
print(5)



with ThreadPoolExecutor\ProcessPoolExecutor(max_workers=5) as executor:
executor.submit(child_1)
executor.submit(child_2)
executor.submit(child_3)
executor.submit(child_4)
executor.submit(child_5)


t1= executor.submit(child_1)
t2=executor.submit(child_2)
t3=executor.submit(child_3)
t4=executor.submit(child_4)
t5=executor.submit(child_5)

print(t1.result())

作死的头像

销售 副业 写代码 ？？？ 6666

引起不适，block