我想在共享内存机器上使用异步并行来并行处理一个时态图(本质上是一个networkx图的列表)。为了实现这一点,我使用multiprocessing模块中的Pool.apply_async()。对于每个单元图,我执行多个计算开销很大的矩阵操作。):
File "/usr/lib/python3.8/multiprocessing/pool.py", line 12
我有一套我的程序与之通信的仪器,我想把通讯放在一个单独的线程中。IO相当慢(每台仪器每项约100 ms ),我需要将它们的结果值记录在一个共享数组中(最后一个N值),并保存到一个文件中,并尽可能快地进行重复测量。我希望所有这些都是在一个单独的线程中完成的,这样时间就不会被主线程中发生的计算等所交错,但是主线程应该能够访问数组。理想情况下,我应该能够运行一些daq.start(),它可以在没有进一步交