### Linux 下使用 C++ 实现 fork 和消息队列进行进程间通信 在 Linux 环境下，可以利用 `fork` 创建子进程并结合 POSIX 消息队列来实现进程间的通信。POSIX 消息队列是一种高效的 IPC（Inter-Process Communication）机制，允许不同进程之间传递数据。 #### 使用 C++ 的 Fork 和消息队列示例代码 以下是基于 C++ 的一个简单例子，展示如何创建父子进程并通过消息队列进行通信： ```cpp #include <iostream> #include <sys/types.h> #include <unistd.h> #include <mqueue.h> // For message queues #include <cstring> int main() { pid_t pid; mqd_t mq; // Message queue descriptor const char* mq_name = "/my_mq"; struct mq_attr attr; // Set attributes of the message queue attr.mq_flags = 0; attr.mq_maxmsg = 10; // Max number of messages in queue attr.mq_msgsize = 256; // Maximum size of a single message // Create or open the message queue mq = mq_open(mq_name, O_CREAT | O_RDWR, 0644, &attr); if (mq == -1) { std::cerr << "Failed to create/open message queue." << std::endl; return 1; } pid = fork(); if (pid == -1) { // Error occurred std::cerr << "Fork failed!" << std::endl; return 1; } else if (pid == 0) { // Child process char buffer[256]; ssize_t bytes_read = mq_receive(mq, buffer, sizeof(buffer), nullptr); if (bytes_read != -1) { buffer[bytes_read] = '\0'; std::cout << "Child received: " << buffer << std::endl; } } else { // Parent process const char* msg = "Hello from parent!"; if (mq_send(mq, msg, strlen(msg) + 1, 0) == -1) { std::cerr << "Message send failed!" << std::endl; } } sleep(1); // Give time for processes to finish their tasks mq_close(mq); // Close the message queue mq_unlink(mq_name); // Remove the message queue when done return 0; } ``` 上述代码展示了父进程向子进程发送一条消息的过程[^1]。 --- ### 利用 Python PyQt5 构建 GUI 并调用 C++ 程序 为了通过 Python 调用 C++ 程序，可以借助外部工具库如 `subprocess` 或者更高级别的接口绑定技术（例如 `ctypes`, `cffi`）。这里提供一种简单的方案：先编译 C++ 程序为可执行文件，再由 Python 中的 PyQt5 提供图形化界面控制其运行逻辑。 #### 安装依赖项 确保安装了必要的开发环境和包： ```bash sudo apt-get install python3-pyqt5 build-essential g++ pip install pyqt5 ``` #### 编写 Python PyQt5 GUI 示例代码 以下是一个基本的 PyQt5 应用程序，用于启动/停止 C++ 进程管理器，并显示日志信息。 ```python import sys from PyQt5.QtWidgets import QApplication, QMainWindow, QPushButton, QVBoxLayout, QWidget, QTextEdit from subprocess import Popen, PIPE class MainWindow(QMainWindow): def __init__(self): super().__init__() self.setWindowTitle("C++ Process Manager") layout = QVBoxLayout() self.text_edit = QTextEdit() self.start_button = QPushButton("Start Processes") self.stop_button = QPushButton("Stop Processes") self.process = None # Connect buttons to functions self.start_button.clicked.connect(self.start_processes) self.stop_button.clicked.connect(self.stop_processes) layout.addWidget(self.text_edit) layout.addWidget(self.start_button) layout.addWidget(self.stop_button) container = QWidget() container.setLayout(layout) self.setCentralWidget(container) def start_processes(self): if not self.process: try: self.process = Popen(['./a.out'], stdout=PIPE, stderr=PIPE, text=True) while True: output = self.process.stdout.readline().strip() if output == '' and self.process.poll() is not None: break if output: self.text_edit.append(output) except Exception as e: self.text_edit.append(f"Error starting process: {e}") def stop_processes(self): if self.process: self.process.terminate() self.process.wait() self.text_edit.append("Processes stopped.") self.process = None app = QApplication(sys.argv) window = MainWindow() window.show() app.exec_() ``` 此脚本定义了一个窗口应用程序，其中包含两个按钮：“Start Processes” 启动 C++ 可执行文件，“Stop Processes” 停止它。日志输出会实时更新到文本框中[^2]。 --- ###