如何创建/控制并行工作器?

问题描述

我有一个python程序,可以在sql数据库上做一些工作。我想创建一些多线程工作程序来处理与数据库的连接。我已经搜索了诸如ThreadPoolExecutor之类的解决方案,但是我需要控制该工作分配给哪个工人。

有用的信息:

  • 每个作业只能访问一个表。
  • 同一张表的作业不能同时运行。
  • 作业是异步创建的。

我正在寻找有关如何实现此目标或如何更改代码逻辑的建议。

编辑:
对于上下文,我对代码进行了简化:

async def UpdatePlayer(profile_id):
    # retrieve data from website
    # computation on said data
    database_edit_row(args)

async def ShowPlayer(profile_id):
    database_get_row(args)
    print(data)

在阅读评论时,我曾考虑过为每个行会创建一个新工作人员,但由于我计划同时与数百个用户一起工作,因此我认为它的扩展性不好。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)