文章详情

登录

短信预约-IT技能 免费直播动态提醒

选择考试省份

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团

请输入下面的图形验证码

提交验证

短信预约提醒成功

你真的了解线程的基础知识吗？这些技巧让你的代码更高效！

2024-11-30 11:09

关注

当涉及到多任务处理时，线程是一种非常实用的技术。Python语言提供了内置的线程支持库，使得创建和管理线程变得非常容易。本文将深入介绍Python中的线程概念，线程创建和管理，线程状态和生命周期，线程的属性和方法以及线程的调度和优先级。

线程概念和基本原理

线程是进程中的执行单元，每个线程都有自己的执行路径和执行状态。一个进程可以包含多个线程，每个线程都可以同时执行不同的任务。线程是轻量级的，开销小，执行效率高，因此在高并发和多任务处理场景中得到广泛应用。

在Python中，线程是通过threading模块实现的。创建线程可以使用Thread类或继承Thread类自定义线程。线程的创建和启动可以使用start()方法。

import threading

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)

# 创建线程
t1 = threading.Thread(target=print_numbers)
t2 = threading.Thread(target=print_numbers)

# 启动线程
t1.start()
t2.start()

上面代码中，我们创建了两个线程t1和t2，用于执行print_numbers函数。通过start()方法启动线程后，两个线程会同时执行print_numbers函数。

线程的状态和生命周期

线程在运行过程中会出现不同的状态，包括新建状态、就绪状态、运行状态、阻塞状态和终止状态。线程的状态可以通过is_alive()方法查询。

线程的生命周期包括线程创建、线程就绪、线程运行、线程阻塞和线程终止。线程的生命周期可以通过join()方法控制。

import threading

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)

# 创建线程
t1 = threading.Thread(target=print_numbers)
t2 = threading.Thread(target=print_numbers)

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

print("All threads have finished")

上面代码中，我们使用join()方法等待线程t1和t2执行完毕后才输出"All threads have finished"。这种等待方式可以保证主线程在所有子线程执行完毕后再退出。

线程的属性和方法

Python中的线程有很多属性和方法，可以让我们更加灵活地控制线程的执行。下面将详细讲解线程的属性和方法，以及每个方法的作用和代码示例。

线程属性

name属性

name属性用于获取或设置线程的名称。线程的名称可以是任意字符串。

import threading

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)

# 创建线程并设置名称
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 获取线程名称
print(t1.name)
print(t2.name)

# 启动线程
t1.start()
t2.start()

daemon属性

daemon属性用于设置线程是否为守护线程。守护线程是一种特殊的线程，当所有非守护线程执行完毕后，守护线程自动退出。

import threading
import time

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)
        time.sleep(0.5)

# 创建线程并设置为守护线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2", daemon=True)

# 获取线程守护状态
print(t1.daemon)
print(t2.daemon)

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

print("All threads have finished")

ident属性

ident属性用于获取线程的标识符。线程的标识符是一个整数，唯一标识该线程。

import threading

# 线程函数
def print_ident():
    print(threading.current_thread().name, ":", threading.current_thread().ident)

# 创建线程
t1 = threading.Thread(target=print_ident, name="Thread 1")
t2 = threading.Thread(target=print_ident, name="Thread 2")

# 启动线程
t1.start()
t2.start()

is_alive()方法

is_alive()方法用于判断线程是否在运行。

import threading
import time

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)
        time.sleep(0.5)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

# 判断线程是否在运行
print(t1.is_alive())
print(t2.is_alive())

线程方法

start()方法

start()方法用于启动线程。一旦线程启动，它将执行target指定的函数。

import threading
import time

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)
        time.sleep(0.5)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 启动线程
t1.start()
t2.start()

join()方法

join()方法用于等待线程执行完毕。如果不使用join()方法，主线程将在子线程之前结束，导致子线程被强制结束。

import threading
import time

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)
        time.sleep(0.5)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

print("All threads have finished")

run()方法

run()方法是线程执行时调用的方法。默认情况下，run()方法调用target指定的函数。

import threading
import time

# 线程类
class MyThread(threading.Thread):
    def run(self):
        for i in range(10):
            print(self.name, ":", i)
            time.sleep(0.5)

# 创建线程
t1 = MyThread(name="Thread 1")
t2 = MyThread(name="Thread 2")

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

print("All threads have finished")

sleep()方法

sleep()方法用于将线程休眠一段时间。在休眠期间，线程不会执行任何操作。

import threading
import time

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)
        time.sleep(0.5)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

# 休眠线程
time.sleep(1)

print("All threads have finished")

enumerate()方法

enumerate()方法用于返回当前正在运行的所有线程。

import threading

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 启动线程
t1.start()
t2.start()

# 获取所有正在运行的线程
for thread in threading.enumerate():
    print(thread.name)

active_count()方法

active_count()方法用于返回当前正在运行的线程数。

import threading

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 启动线程
t1.start()
t2.start()

# 获取正在运行的线程数
print(threading.active_count())

线程的调度和优先级

线程调度是指多个线程之间的竞争和协作机制，通过优先级和时间片轮转等方式来调度线程的执行。Python中可以通过threading模块的setpriority()方法设置线程的优先级。线程的优先级可以是整数，范围为0到sys.maxsize。

在Python中，线程的优先级仅仅是一个建议，具体的线程调度由操作系统来完成。

import threading

# 线程函数
def print_numbers():
    for i in range(10):
        print(threading.current_thread().name, ":", i)

# 创建线程
t1 = threading.Thread(target=print_numbers, name="Thread 1")
t2 = threading.Thread(target=print_numbers, name="Thread 2")

# 设置线程优先级
t1.setpriority(1)
t2.setpriority(2)

# 启动线程
t1.start()
t2.start()

# 等待线程结束
t1.join()
t2.join()

print("All threads have finished")

上面代码中，我们使用setpriority()方法设置线程的优先级，t1的优先级为1，t2的优先级为2。线程的优先级越高，在竞争CPU资源时就越有可能被调度执行。

总结

本文介绍了Python中线程的基础知识，包括线程概念和基本原理，线程的创建和管理，线程状态和生命周期，线程的属性和方法以及线程的调度和优先级。如果您需要在Python中进行多任务处理，线程将是一个非常实用的技术，可以提高程序的效率和性能。

来源：今日头条内容投诉

免责声明：

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题

  • 2024年上半年信息系统项目管理师第二批次真题及答案解析（完整版）

    难度     813人已做
    查看

  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看

  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看

  • 2024年上半年软考高项第一、二批次真题考点汇总（完整版）

    难度     435人已做
    查看

  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机

你真的了解线程的基础知识吗？这些技巧让你的代码更高效！

后端开发Python线程状态2024-11-30

你真的了解 Python 并发编程吗？掌握这些 bash 函数，让你的代码更高效！

后端开发2023-07-08

你真的了解ForkJoinPool吗？这些技巧让你的代码性能提升十倍！

后端开发Java72024-11-30
位置：首页-资讯-后端开发
咦！没有更多了？去看看其它编程学习网 内容吧
首页课程
资料下载问答资讯