编程学习网 > 编程语言 > Python > python 线程教程(Python多线程方法详解)
2023
07-01

python 线程教程(Python多线程方法详解)

本文介python多线程,关于多线程概念本文不过多介绍,主要介绍多线程的使用。

Python3 线程中常用的两个模块为:
_thread
threading (推荐使用)
thread 模块已被废弃。用户可以使用 threading 模块代替。所以,在 Python3 中不能再使用thread 模块。为了兼容性,Python3 将 thread 重命名为 _thread。

1 _thread模块使用
_thread 模块通过函数start_new_thread来开启新线程, 其使用方式如下:

_thread.start_new_thread(function, args[, kwargs] )
各个参数含义如下:

function: 线程函数,用于新线程起始执行。
args: 线程函数的参数,必须是个元组(tuple)类型。
kwargs: 可选参数。
以具体示例学习:

import _thread
import time

# 线程启动函数
def worker( threadName, delay):
   while True:
        now = time.localtime() 
        print(threadName, time.strftime("%Y-%m-%d %H:%M:%S", now))
        time.sleep(delay)

# 开启两个线程
#线程1每秒打印一次
_thread.start_new_thread(worker, ("线程1", 1))
#线程2每4秒打印一次
_thread.start_new_thread(worker, ("线程2", 4))
 
# 通过循环,让主线程不要退出
while 1:
   time.sleep(1000)
输出结果如下:

线程1 2022-01-08 12:12:24
线程2 2022-01-08 12:12:24
线程1 2022-01-08 12:12:25
线程1 2022-01-08 12:12:26
线程1 2022-01-08 12:12:27
线程1 2022-01-08 12:12:28
线程2 2022-01-08 12:12:28
2 threading模块使用
threading包含的方法
threading模块包含_thread模块中的所有方法,并且还包含如下方法:

threading.currentThread(): 返回当前的线程变量。
threading.enumerate(): 返回一个包含正在运行的线程的列表。正在运行指线程启动后、结束前,不包括启动前和终止后的线程。
threading.activeCount(): 返回正在运行的线程数量,与len(threading.enumerate())有相同的结果。
注意,在threading中没有start_new_thread函数,而是更改为_start_new_thread函数

threading的Thread类
除了使用方法外,线程模块同样提供了Thread类来处理线程,Thread类提供了以下方法:

run(): 用以表示线程活动的方法。
start():启动线程活动。
join([time]): 等待至线程中止。这阻塞调用线程直至线程的join()方法被调用中止、正常退出、抛出未处理的异常、超时发生等。
isAlive(): 返回线程是否活动的。
getName(): 返回线程名。
setName(): 设置线程名。
接下来我们介绍Thread类的方式开启线程。

import threading
from threading import Thread
import time

class MyThread(Thread):
    def __init__(self, name, delay):
        threading.Thread.__init__(self)
        self.name = name
        self.delay = delay
        self.count = 0

    def run(self):
        print("进入线程", self.name)
        while self.count < 3:
            now = time.localtime() 
            print(self.name, time.strftime("%Y-%m-%d %H:%M:%S", now))
            time.sleep(self.delay)
            self.count += 1
        print("退出线程", self.name)

# 创建新线程
thread1 = MyThread("线程1", 1)
thread2 = MyThread("线程2", 4)

# 开启新线程
thread1.start()
thread2.start()
thread1.join()
thread2.join()
print ("退出主线程")
输出结果如下:

进入线程 线程1
线程1 2022-01-08 12:25:45
进入线程 线程2
线程2 2022-01-08 12:25:45
线程1 2022-01-08 12:25:46
线程1 2022-01-08 12:25:47
退出线程 线程1
线程2 2022-01-08 12:25:49
线程2 2022-01-08 12:25:53
退出线程 线程2
退出主线程

可以看到,线程2每次睡眠4秒,所以线程1运行结束后,线程2还在持续跑。等到所有线程结束,即thread1.join()和thread2.join()执行完成后,主线程才推出。

以上就是python 线程教程(Python多线程方法详解)的详细内容,想要了解更多Python教程欢迎持续关注编程学习网。

扫码二维码 获取免费视频学习资料

Python编程学习

查 看2022高级编程视频教程免费获取