python基础篇:多线程的基本使用

liftword1个月前 (03-31)技术文章4

Python多线程是一种并发编程的方式,可以让程序同时执行多个任务。在Python中,多线程可以使用标准库中的threading模块来实现。本文将介绍如何使用threading模块来创建和管理线程。

创建线程

在Python中,创建线程可以通过创建Thread对象来实现。Thread对象有一个target参数,指定线程要执行的函数。例如:

在这个例子中,我们创建了一个名为print_numbers的函数,并将其作为Thread对象的target参数传递。然后我们调用start()方法来启动线程。当线程启动后,它将调用print_numbers函数来执行任务。

传递参数

有时候我们需要在线程中传递参数。可以通过在Thread对象的args参数中传递参数。例如:

在这个例子中,我们传递了start和end两个参数给print_numbers函数。将这些参数作为元组传递给args参数,即args=(1, 10)。在print_numbers函数中,我们使用这些参数来打印数字。

线程同步

在多线程编程中,线程之间可能会访问共享资源。如果没有适当的同步机制,可能会导致竞态条件和死锁等问题。Python提供了多种同步机制,例如锁(Lock)信号量(Semaphore)条件变量(Condition)等。这里以锁为例,介绍如何在Python中使用锁来实现线程同步。

在这个例子中,我们定义了两个函数incrementdecrement,分别对全局变量x进行加一和减一操作。为了避免竞态条件,我们使用Lock对象来控制对x的访问。在incrementdecrement函数中,我们调用acquire()方法来获取锁,然后进行相应的操作,最后调用release()方法来释放锁。这样,每个线程在访问x时都会先获得锁,从而避免了竞态条件。

在这个例子中,我们创建了两个线程thread1thread2,分别执行incrementdecrement函数。我们通过调用start()方法来启动线程,然后通过调用join()方法来等待线程执行完毕。最后,我们打印x的值,以检查线程同步是否正确。

线程池

在Python中,可以使用ThreadPoolExecutor类来创建线程池,以便同时执行多个任务。ThreadPoolExecutor可以自动管理线程的数量和生命周期,从而避免创建过多线程导致系统负载过高的问题。

以下是一个简单的示例:

在这个例子中,我们使用ThreadPoolExecutor创建了一个最大工作线程数为2的线程池。然后我们通过调用submit()方法来提交两个任务,分别打印1到5和6到10之间的数字。

submit()方法返回一个Future对象,用于表示任务的执行状态和结果。在这个例子中,我们没有使用Future对象来获取任务的结果,而是直接打印数字。

Future对象的作用

Future对象是在Python标准库中的concurrent.futures模块中提供的一种异步编程工具,用于表示一个尚未完成的异步操作的状态和结果。

当一个任务被提交到线程池或者进程池中时,会立即返回一个Future对象。这个对象可以用于查询任务的状态和结果。Future对象有以下几种状态:

  • PENDING:任务尚未开始执行。
  • RUNNING:任务正在执行。
  • CANCELLED:任务已被取消。
  • FINISHED:任务已完成,可能成功也可能失败。

当任务完成后,Future对象会保存任务的结果,可以通过调用result()方法来获取。如果任务尚未完成,调用result()方法会阻塞当前线程,直到任务完成并返回结果或者抛出异常。

除了result()方法之外,Future对象还提供了一些其他的方法,例如cancel()方法可以用于取消任务,done()方法用于检查任务是否完成,add_done_callback()方法可以用于注册回调函数,当任务完成时自动调用。

综合演示例子

下面是一个综合的例子,演示如何使用concurrent.futures模块中的ThreadPoolExecutor和Future对象来实现并发下载图片的功能。

  • 在这个例子中,我们定义了一个download_image()函数,用于下载指定URL对应的图片,并将图片保存到本地文件系统中。然后我们定义了一个URL列表urls,包含了要下载的五张图片的URL地址。
  • 接下来,我们使用ThreadPoolExecutor创建一个线程池,并使用submit()方法提交五个下载任务。submit()方法返回一个Future对象,代表了提交的任务。我们将所有的Future对象保存在一个列表中。
  • 然后,我们使用as_completed()函数遍历所有的Future对象,并在每个Future对象完成后调用result()方法获取结果。如果下载成功,就打印出文件名。

通过使用ThreadPoolExecutor和Future对象,我们可以同时下载多个图片,从而提高下载速度。同时,使用Future对象可以让我们方便地处理每个任务的结果,从而实现更加灵活的异步编程。

总结

本文介绍了如何在Python中使用threading模块来创建和管理线程,包括传递参数、线程同步和线程池等方面。同时,我们也介绍了一些常见的多线程编程问题,例如竞态条件和死锁等,以及如何使用锁来避免这些问题。在实际编程中,需要根据具体情况选择适当的同步机制和线程池配置,以提高程序的性能和稳定性。

相关文章

python笔记47:多线程详解

主要内容:小目标:掌握多线程;主要内容:线程类使用,多线程使用;1. 线程基本概念线程概念:线程是轻量级进程,是操作系统能够进行运算调度的最小单位;线程依赖进程资源,是进程中的实际运作单位;一个进程中...

Python中的多线程详解,让你的程序飞起来!

Python是一门高级编程语言,拥有简单易用、面向对象、可扩展等优点,因此被广泛应用于各种领域。但是在Python中,由于GIL(全局解释器锁)的存在,导致了多线程的效率不高。但是,对于某些IO密集型...

Python多线程编程到底怎么玩?核心技巧与注意事项全知道!

在 Python 中,多线程编程主要用于处理 I/O 密集型任务(如网络请求、文件读写、数据库操作等),但由于 全局解释器锁(GIL) 的存在,多线程对 CPU 密集型任务 的性能提升有限(此时建议使...

小白都看懂了,Python 中的线程和进程精讲,建议收藏

目录线程和进程一、 什么是进程 / 线程1、 引论众所周知,CPU是计算机的核心,它承担了所有的计算任务。而操作系统是计算机的管理者,是一个大管家,它负责任务的调度,资源的分配和管理,统领整个计算机硬...

Python多线程

本文重点探究以下几个问题:多线程内存共享线程类获取线程结果方法:join/setDaemon对线程退出的作用线程无法利用多核,不是真正的并发多线程内存共享多个线程访问同一内存变量时,需要通过锁机制来实...

Python 多线程居然是——假的?

作者:李晓飞来源:Python 技术不过最近有位读者提问:Python 的多线程真是假的吗?一下子点到了 Python 长期被人们喜忧参半的特性 —— GIL 上了。到底是怎么回事呢?今天我们来聊一聊...