多线程并发问题：Python并发编程实例分析

原创叁歲伎倆 2025-03-22 10:03 74阅读 0赞

Python的并发编程主要通过threading模块和asyncio模块实现。下面是一个简单的多线程并发编程实例分析：

1. **基础概念**：
   - **Thread**：Python中的线程，通过Thread类创建。
   - **Lock**：用于控制对共享资源的访问，如threading.Lock()。
   - **Event**：用于通知线程改变的状态，如threading.Event()。

2. **实例分析**：
   - **创建线程**：
     ```python
     import threading

def worker_thread(name):
         print(f'Thread {name} starting...'))
         time.sleep(2)
         print(f'Thread {name} finished!'))
     
     thread1 = threading.Thread(target=worker_thread, args=("Thread 1",)))
     thread2 = threading.Thread(target=worker_thread, args=("Thread 2",)))

# 启动线程
     thread1.start()
     thread2.start()

# 等待所有线程完成
     thread1.join()
     thread2.join()
     ```
   - **使用锁控制资源访问**：
     ```python
     import threading

lock = threading.Lock()

def worker_thread(name, resource):
         with lock:
             print(f'Thread {name} starting...'))
             time.sleep(2)
             print(f'Thread {name} finished! Accessing resource: {resource}')

# 控制资源访问，这里模拟一个文件
         if resource == "file":
             # 等待其他线程完成后再关闭文件
             lock.acquire()
             try:
                 open_resource('file.txt', 'w').close()
             finally:
                 lock.release()

thread1 = threading.Thread(target=worker_thread, args=("Thread 1", "resource",))))
     thread2 = threading.Thread(target=worker_thread, args=("Thread 2", "file",))))

# 启动线程
     thread1.start()
     thread2.start()

# 等待所有线程完成
     thread1.join()
     thread2.join()
     ```
3. **总结**：
   - Python并发编程是多线程和锁（如threading.Lock()）的结合。
   - 通过实例，我们可以看到如何在多个任务之间共享资源并控制访问。

记住，理解和实践编程总是最好的学习方式。