Python从入门到精通之多线程使用详解

import threading
# 继承Thread类创建线程
class MyThread(threading.Thread):
    def run(self):
        # 线程执行的代码
        print("Hello, World!")
        # 使用函数创建线程
def my_function():
    # 线程执行的代码
    print("Hello, World!")
    # 创建线程对象并启动线程
thread1 = MyThread()
thread2 = threading.Thread(target=my_function)
thread1.start()
thread2.start()

import threading
# 共享资源
count = 0
# 创建互斥锁
lock = threading.Lock()
def increment():
    global count
    # 获取锁
    lock.acquire()
    try:
        # 修改共享资源
        count += 1
    finally:
        # 释放锁
        lock.release()
        # 创建多个线程并启动
threads = []
for _ in range(10):
    thread = threading.Thread(target=increment)
    threads.append(thread)
    thread.start()
    # 等待所有线程结束
for thread in threads:
    thread.join()
    # 打印结果
print("Count:", count)

import threading
import queue
# 创建队列对象
q = queue.Queue()
def producer():
    for i in range(5):
        # 生产数据
        q.put(i)
        print("Produced:", i)
def consumer():
    while True:
        # 获取数据
        data = q.get()
        if data is None:
            break
        print("Consumed:", data)
        # 创建生产者线程和消费者线程
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)
# 启动线程
producer_thread.start()
consumer_thread.start()
# 等待生产者线程结束
producer_thread.join()
# 添加终止标志到队列
q.put(None)
# 等待消费者线程结束
consumer_thread.join()

import concurrent.futures
# 定义任务函数
def my_task(name):
    print("Task", name, "is running.")
    # 创建线程池
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
    # 提交任务
    for i in range(5):
        executor.submit(my_task, i)