如何从外部终止线程或在python的多处理中使用输入

import threading

stop_event = threading.Event()

def my_thread_function():
    while not stop_event.is_set():
        # 线程的任务逻辑
        pass

stop_event.set()

import multiprocessing

process = multiprocessing.Process(target=my_process_function)

process.terminate()

import multiprocessing
import threading
import queue

def my_thread_function(shared_data, data_queue):
    while True:
        # 从队列获取输入数据
        input_data = data_queue.get()

        # 使用共享数据处理输入数据
        with shared_data.get_lock():
            shared_data.value += input_data

        # 处理完输入数据后退出循环
        if input_data == 'exit':
            break

def my_process_function(shared_data, data_queue):
    while True:
        # 从队列获取输入数据
        input_data = data_queue.get()

        # 使用共享数据处理输入数据
        with shared_data.get_lock():
            shared_data.value += input_data

        # 处理完输入数据后退出循环
        if input_data == 'exit':
            break

if __name__ == '__main__':
    # 创建共享数据和队列
    shared_data = multiprocessing.Value('i', 0)
    data_queue = multiprocessing.Queue()

    # 创建线程和进程
    thread = threading.Thread(target=my_thread_function, args=(shared_data, data_queue))
    process = multiprocessing.Process(target=my_process_function, args=(shared_data, data_queue))

    # 启动线程和进程
    thread.start()
    process.start()

    # 向队列传递输入数据
    data_queue.put(10)
    data_queue.put(20)
    data_queue.put('exit')

    # 等待线程和进程结束
    thread.join()
    process.join()

    # 打印共享数据的结果
    print(shared_data.value)