python 向主线程发送数据

在Python中，如果你想要在一个线程（如子线程或其他并发任务）向主线程发送数据，你可以使用`queue`模块提供的队列数据结构。例如，可以使用`Queue`、`multiprocessing.Queue`或`concurrent.futures.ThreadPoolExecutor`中的`Queue`来实现实时通信。

以下是一个简单的例子：

import queue
import threading

# 创建一个队列
data_queue = queue.Queue()

def worker_thread(data_queue):
    # 子线程函数，从队列中接收数据并处理
    while True:
        data = data_queue.get()
        # 这里假设我们对数据进行了某种处理
        processed_data = process_data(data)
        print(f"Processed data: {processed_data}")

def main():
    # 在主线程中添加数据到队列
    for i in range(10):
        data_queue.put(i)

    # 开启子线程
    thread = threading.Thread(target=worker_thread, args=(data_queue,))
    thread.start()

    # 等待子线程完成
    thread.join()

    # 主线程结束，关闭队列（如果有必要）
    data_queue.put(None)  # 通知工作线程停止
    thread.join()  # 确保线程安全地结束

def process_data(data):
    # 这里只是一个示例，实际过程可能会更复杂
    return f"Data received: {data}"

if __name__ == "__main__":
    main()

在这个例子中，`data_queue.put()`用于将数据放入队列，而`worker_thread`通过循环不断从队列取出数据。当主线程完成后，可以通过向队列添加`None`来告诉工作线程终止。