Python并发编程线程咋管理_运维文库_资讯中心

发布时间:2026-04-29 07:31:27

阅读量:2

在Python中，可以使用threading模块来创建和管理线程。以下是一些关于如何使用threading模块进行线程管理的建议：

导入threading模块：

import threading

创建一个线程类，继承自threading.Thread：

class MyThread(threading.Thread):
    def __init__(self, target, args=()):
        super().__init__()
        self.target = target
        self.args = args

    def run(self):
        self.target(*self.args)

在这个例子中，我们创建了一个名为MyThread的线程类，它接受一个目标函数和参数作为输入。run方法用于定义线程要执行的任务。

创建线程实例：

def my_function():
    print("Hello from my function!")

thread = MyThread(my_function)

在这个例子中，我们创建了一个名为my_function的简单函数，然后使用MyThread类创建了一个线程实例。

启动线程：

thread.start()

调用start方法将启动线程并执行run方法中的任务。

等待线程完成：

thread.join()

调用join方法将阻塞主线程，直到被调用的线程完成执行。

使用threading.Lock来同步线程：

lock = threading.Lock()

def my_function():
    global counter
    for _ in range(100000):
        lock.acquire()
        counter += 1
        lock.release()

counter = 0
thread = MyThread(my_function)
thread.start()
thread.join()
print("Counter:", counter)

在这个例子中，我们使用threading.Lock来确保在同一时间只有一个线程可以访问共享资源（counter变量）。

使用threading.Semaphore来限制同时运行的线程数量：

semaphore = threading.Semaphore(3)

def my_function(id):
    with semaphore:
        print(f"Thread {id} is running.")

threads = []
for i in range(10):
    thread = MyThread(my_function, args=(i,))
    threads.append(thread)
    thread.start()

for thread in threads:
    thread.join()