我有一个Dag in air-flow,看起来是这样的:
start >> [task1,task2,....task16] >> end
例如,我希望将在这个进程中同时运行的任务限制为4。
我知道有'max_active_tasks_per_dag'参数,但是它会影响所有dag,在我的例子中,我只想为我的dag定义它。我怎样才能做到呢?甚至有可能吗?
在python多处理中,可以创建一个由30个进程组成的多处理池,以便在某些ID上处理一些长时间运行的等式。下面的代码在一台8核机器上产生30个进程,load_average从未超过2.0。事实上,30个使用者是一个限制,因为承载it的postgresql数据库的服务器有32个核,所以我知道如果我的数据库能够处理它,我可以产生更多的进程。
from multiprocessing import Pool
number_of_consumers = 30
pool = Pool(number_of_consumers)
我花了时间来安装芹菜,但无法重新创建这30个过程。我以为设置并发性,例如-c
关于Linux中的mmap和munmap,我有一个简单的问题:有没有可能mmap成功了,而munmap失败了?
例如,假设所有参数都已正确给出,请参阅以下代码片段。在什么情况下会打印munmap failed!??
char *addr = mmap(NULL, 4096, PROT_READ | PROT_WRITE, MAP_PRIVATE | MAP_ANONYMOUS, -1, 0);
... exit if mmap was not successful ...
... do some stuff using mmaped area ...
if( munmap(addr, 40