问题标签 [multiple-processes]

我有两个c文件，服务器和客户端。服务器侦听并接受来自客户端的连接请求，然后等待打印出客户端提供给它的消息。连接过程完美运行，但我不知道如何让它中继它应该接收的消息。

由于这两个文件是分开的，我不确定将什么文件描述符放入客户端的 write() 调用中。服务器中的 read() 调用在客户端中的 write() 调用之前调用，它使用文件描述符 s2，它是其 accept() 调用的输出。

如何让我的客户端文件中的 write() 调用与我的服务器文件中的 read() 调用正在寻找的同一个套接字进行通信？

下面的代码有一些功能，比如为了时间的缘故省略了错误检查。

这是我的server.c文件的内容：

这是上面块中使用的函数my_pipe() ：

最后，这是我的client.c文件的内容：

运行这两个文件的服务器输出：

我正在按照这里的示例 https://wiki.tcl-lang.org/page/Execute+in+Parallel+and+Wait 但是当我运行这样的简单代码时出现错误：子进程异常退出并且错误是“错误：无法找到或加载主类原因：java.lang.ClassNotFoundException：”

尝试通过在 forloop 中运行此执行语句以稍微不同的方式运行并行进程时，我收到了类似的消息

我必须运行所有 50 个 chrome。我想总是同时运行 5 个 chrome。如果 1 in 5 chrome 先关闭，它将运行 1 chrome new。直到 50 镀铬完成。

示例：5 chrome 正在运行。如果 chrome 3 先关闭，chrome 6 将运行。所以它总是同时运行 5 个 chrome。

我该怎么做？

我尝试使用 ray 来抓取一些数据。

我在使用 ray 之前的原始代码如下，并且运行良好。

我使用 ray 参考 ray 教程，这使我的内核死了：

我通过 jupyter 和 spyder 尝试了代码，但在这两种情况下内核都死了。

我不认为原因是内存不足。它不会使用太多内存。

可能的原因是什么？

我有 main() 函数，它产生两个单独的子进程。这两个子流程共享指标。如何共享两个流程的指标并保持更新？这是我的片段，以供更多理解。

我能够在端点看到指标名称，但计数始终为零意味着它永远不会被子流程更新。

我一直在尝试使用 python 中的多处理来实现多生产者和多消费者模型。生产者从网络上抓取数据，消费者处理数据。起初我只是实现了两个具有特定功能的函数生产者和消费者，并使用队列在它们之间进行通信，但不知道如何处理完成事件。然后我使用信号量实现了模型 -

当 (In Consumer) RESP_q 为空且 SEM 接近 max_process 并且解释器满足 while 条件时，此实现失败，SEM 将具有与 max_process 相同的值，并且不会留下任何生产者，并且程序在 get 方法处被阻塞。我无法解决这个问题。

编辑 1。

@Louis Lac 的实现也是正确的。我更正了我的代码以使用 try-except 块消除死锁。

第一个 while 循环需要一直运行，直到用户输入 1。（假设在子进程中运行）。

第二个 while 循环将是后台运行的守护进程，每 1 秒记录一次计数器。

这是应该一直运行到用户输入 1 的循环

这是应该在后台运行并从第一次登录计数的守护进程。

在我的代码中，我想在另一个 python 窗口中启动一个函数/脚本（例如，当您运行一个脚本时，会弹出一个后窗口，我希望该脚本管理其他脚本。它们不需要通信）。

类似于多处理，但它们有自己的弹出窗口和输出。之后，他们的所有信息都将写入一个文件。

我已经搜索了相当多的内容，但似乎没有人希望脚本在另一个窗口中运行另一个脚本，可能连续运行 4 或 5 个 python 窗口，每个窗口都使用一个单独的核心。

我有一个应用程序正在使用 managementeventwatcher 监视设备上执行的进程，就像这样......

还有我的处理程序（现在只是登录）......

这是一种享受，我以最少的资源使用成功地捕获了事件创建（而不是 Process.GetProcesses()，它正在锤击资源！），但是我注意到如果运行同一进程的第二个实例，我不会在第二次执行时获得一个事件。

例如，我可以运行计算器，而我的观察者将记录 calc.exe 是否使用所有相关属性执行。如果我然后打开第二个计算器，我的观察者什么也看不到。

我猜我需要稍微修改 WMI 查询，但我的 WMI 是有限的，我没有挣扎。

有人可以帮忙吗？

TIA

我正在尝试创建一个主从模型，其中进程 0（主）将子块从结构数组发送到剩余的 n-1 个进程。这是我的代码的一部分：

bcast_size_dataset_and_sort 函数允许您从文件中读取数据，方法是将它们放置在仅可用于处理 0 的结构 itemset_tids 的数组中，此外，相同的函数允许广播文件中的元素数量（对它们进行排序）-> num_el_P 到所有处理以了解通过 BLOCK_SIZE 宏到达的数据的量化。我已经验证数据到达进程，但这并不总是发生，在某些情况下，接收是在其他所有进程上我有以下类型的错误：

或者

监控我可以发现死锁的过程，但我不明白为什么。谁能帮我理解错误？非常感谢。