mysql.workers
mysql.workers
功能
设置批量 exec 的并发工作数。
语法
mysql(dsn).query(sql).workers(count)
参数
| 参数 | 类型 | 必填 | 默认值 | 说明 |
|---|---|---|---|---|
| count | Int | 否 | 1 | 工作数；有效范围 1 到 4096。 |
返回值
| 类型 | 说明 |
|---|---|
| Mysql | 返回新的 MySQL 查询构建器。 |
示例
rows = [['A'], ['B']] db = mysql('mysql://user:pass@127.0.0.1/test') result = db.query('insert into user(name) values (?)').binds(rows).workers(4).sql() // 输出：insert into user(name) values ('A'), ('B') /* binds: 2 rows, batch: 0, workers: 4 */ print result
注意事项
- 底层 Tokio worker 线程数会被限制到 CPU 并行度和 64 的上限内。
- all() 和 one() 不支持 workers。