Python在线程中获取/发布数据

import threading
import queue

def data_publisher(data_queue):
    # 在线程中发布数据
    data = "Hello, World!"
    data_queue.put(data)

def data_consumer(data_queue):
    # 在线程中获取数据
    data = data_queue.get()
    print(data)

def main():
    # 创建一个线程安全的队列
    data_queue = queue.Queue()

    # 创建发布者线程
    publisher_thread = threading.Thread(target=data_publisher, args=(data_queue,))
    # 创建消费者线程
    consumer_thread = threading.Thread(target=data_consumer, args=(data_queue,))

    # 启动线程
    publisher_thread.start()
    consumer_thread.start()

    # 等待线程结束
    publisher_thread.join()
    consumer_thread.join()

if __name__ == "__main__":
    main()