Python 多线程编程详解：从 thread 模块到锁机制

钢铁男儿

755人浏览 · 2025-09-02 08:35:41

钢铁男儿 · 2025-09-02 08:35:41 发布

在多任务处理日益成为常态的今天，Python 提供了多线程编程的支持，帮助开发者更高效地利用 CPU 资源。本文将围绕 thread 模块，深入探讨其核心函数、线程管理机制，并通过实际代码示例展示如何使用锁（Lock）进行线程同步。我们将从基础概念讲起，逐步深入到代码实现与优化技巧，力求为读者提供一套完整、实用的 Python 多线程编程指南。

一、`thread` 模块概述

thread 模块是 Python 中最早支持多线程的模块之一，虽然它在 Python 3 中已经被重命名为 _thread，并且推荐使用更高级的 threading 模块，但理解其底层机制对于掌握多线程编程至关重要。

1.1 核心函数：`start_new_thread()`

start_new_thread(function, args, kwargs=None) 是 thread 模块的核心函数，用于创建一个新的线程来执行指定的函数。

function：要运行的函数对象。
args：函数的参数，必须是一个元组。
kwargs（可选）：关键字参数。

示例：

import _thread
from time import sleep
 
def my_function(delay):
    print("Start of thread")
    sleep(delay)
    print("End of thread")
 
_thread.start_new_thread(my_function, (2,))

需要注意的是，主线程不会自动等待子线程完成，因此必须通过某种同步机制来协调线程之间的执行顺序。

二、多线程与并发执行：mtsleepA.py 示例

为了展示多线程的优势，我们来看一个简单的例子：两个循环函数分别睡眠 4 秒和 2 秒。如果串行执行，总耗时为 6 秒；而通过多线程并发执行，总耗时将取决于最长的睡眠时间（即 4 秒）。

2.1 示例代码：mtsleepA.py

import _thread
from time import sleep, ctime
 
def loop0():
    print('start loop 0 at:', ctime())
    sleep(4)
    print('loop 0 done at:', ctime())
 
def loop1():
    print('start loop 1 at:', ctime())
    sleep(2)
    print('loop1 done at:', ctime())
 
def main():
    print('starting at:', ctime())
    _thread.start_new_thread(loop0, ())
    _thread.start_new_thread(loop1, ())
    sleep(6)  # 主线程等待足够时间
    print('all DONE at:', ctime())
 
if __name__ == '__main__':
    main()

2.2 输出结果分析

starting at: Sun Aug 13 05:04:50 2006
start loop 0 at: Sun Aug 13 05:04:50 2006
start loop 1 at: Sun Aug 13 05:04:50 2006
loop 1 done at: Sun Aug 13 05:04:52 2006 
loop 0 done at: Sun Aug 13 05:04:54 2006
all DONE at: Sun Aug 13 05:04:56 2006

两个线程并发执行。
loop1 在 loop0 之前结束。
主线程通过 sleep(6) 等待子线程完成。

2.3 存在的问题

硬编码等待时间：sleep(6) 是一种不可靠的方式，无法动态适应不同的线程执行时间。
缺乏同步机制：主线程无法准确判断所有子线程是否完成。

三、引入锁机制：mtsleepB.py 示例

为了解决上述问题，我们引入锁（Lock）来实现线程同步。锁是一种最基本的同步机制，它保证在同一时刻只有一个线程可以访问某个资源。

3.1 锁的基本操作

allocate_lock()：创建一个锁对象。
acquire()：获取锁（阻塞当前线程直到锁可用）。
release()：释放锁。

3.2 示例代码：mtsleepB.py

import _thread
from time import sleep, ctime
 
loops = [4, 2]
 
def loop(nloop, nsec, lock):
    print('start loop', nloop, 'at:', ctime())
    sleep(nsec)
    print('loop', nloop, 'done at:', ctime())
    lock.release()
 
def main():
    print('starting at:', ctime())
    locks = []
    nloops = range(len(loops))
 
    for i in nloops:
        lock = _thread.allocate_lock()
        lock.acquire()
        locks.append(lock)
 
    for i in nloops:
        _thread.start_new_thread(loop, (i, loops[i], locks[i]))
 
    for i in nloops:
        while locks[i].locked():
            pass
 
    print('all DONE at:', ctime())
 
if __name__ == '__main__':
    main()

3.3 输出结果分析

starting at: Sun Aug 13 16:34:41 2006
start loop 0 at: Sun Aug 13 16:34:41 2006
start loop 1 at: Sun Aug 13 16:34:41 2006
loop 1 done at: Sun Aug 13 16:34:43 2006
loop 0 done at: Sun Aug 13 16:34:45 2006
all DONE at: Sun Aug 13 16:34:45 2006