如何将数据写入标准输入，以供等待来自标准输入的单独线程使用？

import threading
import time
import sys

# 生产者线程函数
def producer():
    for i in range(5):
        data = f"Data {i}\n"
        sys.stdout.write(data)  # 写入标准输出，模拟写入标准输入
        sys.stdout.flush()  # 确保数据立即写入
        time.sleep(1)

# 消费者线程函数
def consumer():
    while True:
        line = sys.stdin.readline().strip()
        if line:
            print(f"Consumed: {line}")
        else:
            break

# 创建并启动生产者线程
producer_thread = threading.Thread(target=producer)
producer_thread.start()

# 创建并启动消费者线程
consumer_thread = threading.Thread(target=consumer)
consumer_thread.start()

# 等待生产者线程完成
producer_thread.join()

# 向标准输入写入结束标志
sys.stdin.write("EOF\n")
sys.stdin.flush()

# 等待消费者线程完成
consumer_thread.join()