提交 e0223dc9 编写于 作者: D dingbo

docs: test highvolume_example.py

上级 744df1eb
...@@ -167,13 +167,13 @@ def main(): ...@@ -167,13 +167,13 @@ def main():
task_queues.append(queue) task_queues.append(queue)
p = Process(target=run_write_task, args=(i, queue)) p = Process(target=run_write_task, args=(i, queue))
p.start() p.start()
logging.debug(f"WriteTask {i} started with pid {p.pid}") logging.debug(f"WriteTask-{i} started with pid {p.pid}")
write_processes.append(p) write_processes.append(p)
for i in range(READ_TASK_COUNT): for i in range(READ_TASK_COUNT):
p = Process(target=run_read_task, args=(i, task_queues)) p = Process(target=run_read_task, args=(i, task_queues))
p.start() p.start()
logging.debug(f"ReadTask {i} started with pid {p.pid}") logging.debug(f"ReadTask-{i} started with pid {p.pid}")
read_processes.append(p) read_processes.append(p)
try: try:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册