multiprocess

    0热度

    1回答

    我写了一个无限期运行的Python脚本。它使用PyInotify监视目录,并使用Multiprocessing模块通过外部脚本运行在这些目录中创建的任何新文件。这一切都很好。 我遇到的问题是将输出写入文件。我选择的文件名使用当前日期(使用datetime.now),理论上应该每小时滚动一小时。 now = datetime.now() filename = "/data/db/meta/%s-%

    0热度

    1回答

    我想使用由deco模块提供的并发功能。该代码工作没有多线程如在这里的答案.... Extract specific columns from a given webpage 但是,下面的代码不会对finallist返回任何元素。 (它是空的)。从print语句中可以看出,它在“slow”的函数范围内返回了一些结果。但为什么外表是空的? import urllib.request from bs4

    0热度

    1回答

    我使用这里描述http://www.tornadoweb.org/en/stable/guide/running.html 服务器连接到本地MySQL实例(server.start(n))的第一方法运行在多个流程龙卷风HTTPS服务器我想每个Tornado进程都有一个独立的MySQL连接。 但是,根据SHOW PROCESSLIST的输出,我现在只有一个MySQL连接。我想这是因为我在调用serv

    0热度

    1回答

    我正在用laravel开发一个php应用程序。在我的应用程序中,我需要从一些服务器中获取一些数据。为了加快结果,我必须在同一时间发送这些请求。我发现了laravel队列,但问题是我需要从队列中取回信息。另一种解决方案是php pthreads,但我很难安装它。有没有什么办法(多线程/多处理)做异步作业。

    1热度

    1回答

    我正在使用128核心的linux服务器,但我不是唯一使用它的服务器,所以我想确保我的程序最多使用60个内核。我正在编写的程序是一系列模拟,其中每个模拟都是并行化的。可以选择这种单一仿真的内核数量,我通常使用12.因此,理论上,我可以同时运行这些仿真中的5个,这将导致(5x12)个内核使用60个总。我想从python开始模拟(因为这是所有预处理发生的地方),我的眼睛已经抓住了多处理库,特别是Pool

    2热度

    1回答

    我有在Linux上的IPC机制以下要求: 有一个单一的生产过程,但多消费者的过程。消费者流程不是生产者流程的子女。他们是独立培养的。 正在传输的消息是固定大小的POD结构。 我们需要为此机制使用固定数量的内存。像这样的环形缓冲器看起来很理想。 生产者需要运行得非常快,永远不能等待消费者。相反,它需要覆盖固定大小缓冲区中的条目(对于IPC),并且消费者需要检测这个问题,并且在环绕时跳过中间消息赶上生

    0热度

    1回答

    我有一个字符串列表和每个字符串,我正在做一些更改,您可以在wordify()中看到。现在,为了加快速度,我使用chunked()将列表分成子列表(子列表的数量是CPU核心的数量 - 1)。这样我得到的列表看起来像[[,,],[,,],[,,],[,,]]。 我尽量做到: 我想要做的每一个上同时这些子表wordify(),返回子列表作为单独的列表。我想等到所有过程完成,然后将这些子列表加入到一个列表

    0热度

    1回答

    它似乎工作不同。一个很慢,anthor非常快。 仅仅因为[import demo]?为什么? 缓慢之一: [demo_app.py] import web urls = ('/(.*)', 'demo.hello') app = web.application(urls, globals()) application = app.wsgifunc() if __name__ == "__m

    3热度

    2回答

    我有一个运行在平行几个子流程一个bash的功能,如: #!/bin/bash function check() { set +m for f in foo bar ; do ( if [ -f $f ] ; then ls -la $f >> all; fi ) & done wait } 在采购和运行这个(. scri

    0热度

    1回答

    我有一个应用程序与两个进程。第二个过程在创建活动时开始。发现在清单这项活动的摘录如下: <activity android:name=".ActivityInAnotherProcess" android:process=":anotherprocess" android:launchMode="singleTask" ... 后“:anothe