有个需求，一个线程在得到n个数据之后，异步地执行一个子线程函数，在子线程函数中完成数据库的打开、写入数据、关闭操作。在子线程函数返回前父线程先返回结果。
在此之前，先导入我们需要的模块：

from concurrent.futures import ThreadPoolExecutor
import timeexecutor = ThreadPoolExecutor()

version1

百度了一下，参考这篇文章：python线程实现异步任务
这个代码的执行结果如下：

def update_mysql(id):executor.submit(do_update)return "ok" + str(id)def do_update():time.sleep(3)print('start update')time.sleep(1)print("end")returnprint(update_mysql(1))
print(update_mysql(2))
print(update_mysql(3))

ok1
ok2
ok3
start update
start update
start update
end
end
end

version2

但是这个子线程函数是没有添加参数的，如果我这样写：

def update_mysql(id):executor.submit(do_update(id))return "ok" + str(id)def do_update(id):time.sleep(3)print('start update' + str(id))time.sleep(1)print("end"+ str(id))returnprint(update_mysql(1))
print(update_mysql(2))
print(update_mysql(3))

结果如下：

start update1
end1
ok1
start update2
end2
ok2
start update3
end3
ok3

又变成同步了。

version3

后续又参考了这篇文章:python 之线程池传入多个参数的方法 ThreadPoolExecutor.submit 多参数支持

from concurrent.futures import ThreadPoolExecutor
import timeexecutor = ThreadPoolExecutor()#调用方法
#实质就是通过lambda表达式过渡。传入的参数是一个，但是通过lambda表达多后拆散为多个传入。这是很巧妙的方法，实际 就是 *p 这个表达式。def update_mysql(id):args =[id,id,id]executor.submit(lambda p: doFileParse(*p),args)return "ok" + str(id)def doFileParse(filepath,segment,wordslist):time.sleep(3)print(filepath)time.sleep(1)print(segment)returnprint(update_mysql(1))
print(update_mysql(2))
print(update_mysql(3))

结果如下：

ok1
ok2
ok3
2
1
3
2
1
3

很显然变成了异步执行了，但是却不能保证按照开启顺序执行，但是由于我的子线程不需要保证顺序执行，所以接下来也就不需要探究了。有解决方案的可以告知我一波。

python 线程异步执行踩坑相关推荐

java 线程交给spring_浅谈Java中spring 线程异步执行
多线程并发处理起来通常比较麻烦,如果你使用spring容器来管理业务bean,事情就好办了多了.spring封装了Java的多线程的实现,你只需要关注于并发事物的流程以及一些并发负载量等特性,具体来说 ...
python execute异步执行_封装了一个对mysql进行异步IO的小工具
作者(微信公众号):猿人学Python SanicDB 是为 Python的异步 Web 框架 Sanic 方便操作MySQL而开发的工具,是对 aiomysql.Pool 的轻量级封装.Sanic ...
druid配置：回收线程remove-abandoned使用踩坑
本次踩坑springboot版本2.1.1 druid版本1.1.9 先讲下此次踩坑是怎么回事项目本身为多数据源项目,第二数据源连接了一个只读db,因为该db从库需要进行迁移,所以让这边暂时先连接一 ...
菜鸟在 windows 下 python 中安装 jupyter 踩坑要点、被神化的 VsCode
我平时用不到 python ,更没用过 jupyter ,因此我的 python知识仅限于知道有 python 这么个编程语言,会写个 print("Hello World!!!" ...
python转写java踩坑记录
数组如何初始化 String[] words = new String[]{"1", "2"}; 列表如何由单个对象初始化 Arrays.asList(obj) ...
Python 酷q，踩坑粗记，用慕晓飞大神的sdk
一.安装,此处坑在文档中都有,需要注意的是vs_redit用x86的,文档上的地址我没有试,直接用2008-2019的64位就没成功,安上32位的2017就可以加载dll和json这些文件了二.当时 ...
python sphinx_Python Sphinx使用踩坑记录
描述使用 pip 安装sphinx后,按照教程建立了一个新的py文件,如下 # run.py def run(name): """ this is how we run ...
python访问hive数据库踩坑指南
最近做数据ETL系统的更新,需要将原有ETL任务迁移到新的系统中,并验证数据的准确性. 目录安装依赖包核心代码遇到的坑依赖包版本安装依赖包因为本人电脑是win本,所以只能使用impyla连 ...
Python机器学习核PCA踩坑（numpy库与math库）
only size-1 arrays can be converted to Python scalars 今天学习用Python来实现核PCA,大概是书已经过时的原因(其实就是这个原因).在求核矩阵 ...

python 线程异步执行踩坑

version1

version2

version3

python 线程异步执行踩坑相关推荐

最新文章

热门文章