多线程并发问题：Python中同步与异步操作的案例

原创川长思鸟来 2024-12-30 20:36 6阅读 0赞

在Python中，我们可以使用各种机制来实现同步和异步操作。以下是一些常见的案例：

1. **同步操作**：
   - `threading` 模块：创建线程执行任务。如：
     ```python
     import threading

def task():
         # 执行任务代码
         print("Task executed")

thread = threading.Thread(target=task)
     thread.start()
     ```
   - `queue` 和 `Lock`：使用队列和锁来实现线程安全的同步操作。如：
     ```python
     import queue
     import threading

def producer(q):
         for _ in range(10):
             with q.lock:
                 q.put(("生产任务", _)))
                 print(f"添加任务: {_}")

def consumer(q):
         while True:
             with q.lock:
                 if q.empty():
                     break
                 task = q.get()
                 print(f"消费任务: {task[1]()]}")
                 q.task_done()

q = queue.Queue()
     producer_thread = threading.Thread(target=producer, args=(q,))
     consumer_thread = threading.Thread(target=consumer, args=(q,)))

producer_thread.start()
     consumer_thread.start()

producer_thread.join()
     consumer_thread.join()
     ```
2. **异步操作**：
   - `asyncio` 模块：使用事件循环和协程来实现异步操作。如：
     ```python
     import asyncio

async def my_coroutine():
         print("Coroutine started")
         await asyncio.sleep(1)
         print("Coroutine finished")

event_loop = asyncio.get_event_loop()
     task = event_loop.create_task(my_coroutine())
     task.add_done_callback(lambda t: print(f"Task done: {t.result()})"))
     event_loop.run_until_complete(task)
     ```
这些案例展示了Python中如何通过同步或异步方式来实现线程相关的操作。