使用QueueInput()函数实现Python数据输入队列的方法

在Python中，可以使用Queue模块来实现数据输入队列。Queue模块提供了Queue类，它是一个线程安全的队列，可以用于线程间通信。该模块中的Queue类具有put()和get()方法，可以用来向队列中添加数据和获取队列中的数据。

下面是一个使用Queue模块实现数据输入队列的简单示例：

import queue
import threading

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

# 定义一个生产者线程函数，用于将数据添加到队列中
def producer():
    for i in range(10):
        data_queue.put(i)  # 将数据添加到队列中
        print('Producer put:', i)
        
# 定义一个消费者线程函数，用于从队列中获取数据
def consumer():
    while True:
        data = data_queue.get()  # 从队列中获取数据
        print('Consumer get:', data)
        data_queue.task_done()

# 创建一个生产者线程对象
producer_thread = threading.Thread(target=producer)

# 创建一个消费者线程对象
consumer_thread = threading.Thread(target=consumer)

# 启动生产者和消费者线程
producer_thread.start()
consumer_thread.start()

# 等待生产者和消费者线程执行完毕
producer_thread.join()
consumer_thread.join()

在上面的示例中，我们首先创建了一个Queue对象data_queue，然后定义了一个生产者线程函数producer()和一个消费者线程函数consumer()。在producer()函数中，我们使用put()方法将数据添加到队列中，然后打印出添加的数据；在consumer()函数中，我们使用get()方法从队列中获取数据，然后打印出获取的数据。最后，我们创建了一个生产者线程对象和一个消费者线程对象，并分别启动它们。通过start()方法启动线程后，生产者线程将会开始向队列中添加数据，而消费者线程将会从队列中获取数据。当线程执行完毕后，我们使用join()方法等待线程执行完毕。

使用Queue模块实现数据输入队列可以有效地进行线程间通信，实现数据的安全共享。在实际的应用中，可以根据需要调整生产者和消费者线程的数量，并进行适当的同步控制，以确保数据的正确处理。