python threading_【python标准库学习】thread，threading(一)多线程的介绍和使用

在单个程序中我们经常用多线程来处理不同的工作，尤其是有的工作需要等，那么我们会新建一个线程去等然后执行某些操作，当做完事后线程退出被回收。当一个程序运行时，就会有一个进程被系统所创建，同时也会有一个线程运行，这个线程就是主线程main，在主线程中所创建的新的线程都是子线程，子线程通常都是做一些辅助的事。python中提供了thread和threading两个模块来支持多线程。这篇介绍一下python的多线程和基本使用，下一篇介绍python多线程同步问题。

python中使用线程有两种方式，第一种是用thread模块的start_new_thread函数，另一种是用threading模块的Thread类来包装线程对象。

1.使用thread模块

使用thread模块的start_new_thread函数创建线程并启动。start_new_thread函数原型：

thread.start_new_thread(function, args[, kwargs])

>>> help(thread.start_new_thread)

Help on built-in function start_new_thread in module thread:

start_new_thread(...)

start_new_thread(function, args[, kwargs])

(start_new() is an obsolete synonym)

Start a new thread and return its identifier. The thread will call the

function with positional arguments from the tuple args and keyword arguments

taken from the optional dictionary kwargs. The thread exits when the

function returns; the return value is ignored. The thread will also exit

when the function raises an unhandled exception; a stack trace will be

printed unless the exception is SystemExit.

(END)

这个函数创建一个新线程，并立刻执行函数function，args是该函数function的参数，是一个元组，kwargs是可选的，它为函数提供了命名参数字典。该函数返回一个整数，为线程标示符。function函数执行完后线程正常退出，如果执行过程中有未处理的异常，线程会异常退出。

thread模块的主要函数：

1).start_new_thread()

创建并启动线程执行function函数，function执行完线程退出，或者遇到未处理的异常线程异常退出。

2).thread.exit()

结束当前线程，会触发SystemExit异常，如果没有捕获处理该异常，线程会退出。

3).thread.get_ident()

得到该线程的标示符，就是新建线程时返回的标示符，是一个整数。

4).thread.interrupt_main

在主线程main中触发一个KeyboardInterrupt异常，子线程用这个函数来终止主线程。

5).thread.allocate_lock()

创建一个锁对象LockType，使多个线程同步访问共享资源。

在python中使用多线程更多的是使用第二种方式，即使用threading模块。

2.使用threading模块

threading模块是对thread模块的第二次封装，提供了更好的API来让我们使用。使用threading实现多线程编程都是使用的Thread类，或者Timer类，Timer是Thread的子类，可以指定时间间隔后在执行某个操作：

1 from threading importTimer2

5 defmain():6

7 print ‘timer test!‘

9 t = Timer(3, main)10

11 t.start()

使用Thread类有两种方式，一种是直接创建Thread类的实例，另一种方式是自定义类来继承Thread类。使用Thread类的实例，在它的初始化函数__init__中将可调用的对象作为参数传入，Thread的初始化函数__init__原型：

__init__(self, group=None, target=None, name=None, args=(), kwargs=None, verbose=None);

group和verbose不知道是什么东西，target是可调用对象，线程启动后就执行它，name为线程的名字，默认为"Thread-N"，N为数字，args和kwargs是调用target是的参数列表和关键字参数。

1 from threading importThread2

3 defmain(a, b):4

5 print ‘a:%d, b:%d‘ %(a, b)6

7 Thread(target=main, name=‘newThread‘, args=(1, 2)).start()

自定义类来继承Thread类，然后重写run方法实现我们自己的操作。

from threading importThreadclassMyThread(Thread):def __init__(self, threadName, a, b):

Thread.__init__(self, name=threadName)

self.a=a

self.b=bdefrun(self):print ‘a:%d, b:%d‘ %(self.a, self.b)

myThread= MyThread(‘newThread‘, 1, 2)

myThread.start()

逻辑代码是写在run方法中的，但是我们启动线程都是用的start方法，这两个方法是有区别的，如果直接调用run()方法，只是单纯的调用方法，而调用start()方法是将线程从新建状态启动编程就绪状态，等待cpu的调度，这里涉及到线程的几种状态，start()后线程没有立即运行而是编程就绪状态，当得到cpu时间片后编程运行状态，当run方法结束或者有未处理的异常，线程就结束变成死亡状态等待被回收，在运行状态如果遇到资源没有准备好就会变成阻塞状态，当得到资源后再次编程就绪状态等待cpu的调度。

threading模块的主要类：

1).Thread类

上面已经介绍。

2).Timer类

Thread的子类，上面已经介绍。

3).Lock，RLock，Condition类

同步锁，用于多实现线程同步，资源共享的问题。

4).Event类

用于多线程通信。

多线程同步锁Lock，RLock，Condition和多线程通信Event后面在多线程同步再介绍。

threading模块Thread类的主要函数：

1).Thread.getName()，Thread.setName()

获取和设置线程名字。

2).Thread.ident()

获取线程的标示符，是一个整数。

3).Thread.is_alive()，Thread.isAlive()

判断线程是不是活的，即线程是否已经结束。

4).Thread.activeCount()

获取当前活着的所有线程总数，包括主线程main。

5).Thread.join()

使主线程阻塞，知道该子线程执行完或者超时，它有一个参数timeout表示超时时间，默认为None。

6).Thread.setDaemon()

有一个布尔值的参数，默认为False，该方法设置子线程是否随主线程一起结束。

看看join方法和setDaemon方法：

importthreading， timeclassMyThread(threading.Thread):def __init__(self):

threading.Thread.__init__(self)defrun(self):print ‘thread start‘time.sleep(3)print ‘thread end‘thread1=MyThread()

thread1.start()

time.sleep(1)print ‘start join‘

#thread1.join()

print ‘end join‘

输出结果：

不加thread.join

thread start

start join

end join

thread end

加thread.join

thread start

start join

thread end

end join

主线程中sleep(1)一秒就是为了让线程被调度，线程中sleep(3)三秒就是为了让主线程结束，从两种情况的输出结果可以看出join的功能。

import threading， time

class MyThread(threading.Thread):

def __init__(self):

threading.Thread.__init__(self)

def run(self):

print ‘thread start‘

time.sleep(3)

print ‘thread end‘

print ‘main start‘

thread1 = MyThread()

#thread1.setDaemon(True)

thread1.start()

time.sleep(1)

print ‘main end‘

输出结果：

setDaemon默认为False

main start

thread start

main end

thread end

setDaemon设置为True

main start

thread start

main end

从打印的结果可以看出，当设置为True的时候，线程还在sleep过程就就结束了，以至于thread end这句都没有打印出来。

当然Thread类还不止这些方法，这些只是常用的方法，通过help(Thread)可以查看。

原文地址：https://www.cnblogs.com/liuye1990/p/9392384.html

python threading_【python标准库学习】thread，threading(一)多线程的介绍和使用相关推荐

python标准库学习笔记
原创:python标准库学习笔记数据结构 bisect 模块里实现了一个向列表插入元素时也会顺便排序的算法. struct - 二进制数据结构:用途:在 Python 基本数据类型和二进制数据之间进 ...
python语言的标准库有哪些,python标准库函数有哪些
PyFlux库函数是什么? PyFlux是Python编程语言的开源时间序列库.PyFlux是Python中为处理时间序列问题而创建的开源库. 该库有一系列极好的时间序列模型,包括但不限于 ARIMA ...
Python中级 —— 07标准库
标准库学习 1. The Python Standard Library[https://docs.python.org/3.5/library/] ( 3.5.5 Documentation ) 1 ...
笔记——Python常用的标准库
Python 语言通过模块(module)来组织代码.Python 标准库十分庞大,由C语言编写的内置模块,和由 Python 编写的解决常见开发需求的模块.下面的Python是一些标准库. 库名作 ...
python基础_026__标准库和第三方库
一.标准库与第三方库 1.标准库与第三方库的区别,标准库是python自带的,可以直接import导入, 第三方库需要pip安装/pycharm中下载之后使用 2. 以下是,python自带标准库里 ...
C++的STL标准库学习（queue）队列(第四篇）
queue容器基本概念 Queue是一种先进先出(First In First Out,FIFO)的数据结构,它有两个出口,queue容器允许从一端新增元素,从另一端移除元素. 也就是说输入的数据要 ...
C++的STL标准库学习（stack）栈
stack是一种先进后出(First In Last Out,FILO)的数据结构,它只有一个出口,形式如图所示.stack容器允许新增元素,移除元素,取得栈顶元素,但是除了最顶端外,没有任何其他方法 ...
C++STL标准库学习总结/索引/学习建议
前言: 如果刚刚开始学习STL标准库,不知道从哪里入手学习的话,建议去中国大学mooc平台,先学习北京大学郭炜老师的<程序设计与算法(一)C语言程序设计>(https://www.icou ...
python 删除csv第一行_python 标准库学习之 csv
本文由作者凭海临风授权刊登.原文地址:https://jeffsui.github.io/2020/01/02/python-standard-library-csv/ 文档路径官方文档:htt ...

python threading_【python标准库学习】thread，threading(一)多线程的介绍和使用

python threading_【python标准库学习】thread，threading(一)多线程的介绍和使用相关推荐

最新文章

热门文章