Python マルチスレッド アプリケーションを最適化するための実践的なガイド

import threading


def worker():
    # 线程执行的任务
    print("执行任务")


def main():
    thread_num = 5  # 线程数量
    threads = []

    for i in range(thread_num):
        t = threading.Thread(target=worker)
        t.start()
        threads.append(t)

    for t in threads:
        t.join()

if __name__ == "__main__":
    main()

import threading


def worker(start, end):
    # 线程执行的任务
    for i in range(start, end):
        print("任务{}".format(i))


def main():
    total_tasks = 50  # 总任务数
    thread_num = 5  # 线程数量
    threads = []

    tasks_per_thread = total_tasks // thread_num  # 每个线程处理的任务数

    for i in range(thread_num):
        start = i * tasks_per_thread
        end = (i + 1) * tasks_per_thread
        if i == thread_num - 1:  # 最后一个线程处理剩余的任务
            end = total_tasks

        t = threading.Thread(target=worker, args=(start, end))
        t.start()
        threads.append(t)

    for t in threads:
        t.join()

if __name__ == "__main__":
    main()

import threading


shared_counter = 0  # 共享计数器
lock = threading.Lock()  # 锁对象


def worker():
    global shared_counter

    for _ in range(10000):
        with lock:  # 使用锁来保证对共享资源的互斥访问
            shared_counter += 1


def main():
    thread_num = 5  # 线程数量
    threads = []

    for _ in range(thread_num):
        t = threading.Thread(target=worker)
        t.start()
        threads.append(t)

    for t in threads:
        t.join()

    print("共享计数器的值为：", shared_counter)

if __name__ == "__main__":
    main()