标签：有一个 活动 hang enumerate start 运行 http 时间 函数
本章主要学习如何使用多线程
github博客传送门
csdn博客传送门
threading常用方法:
threading.Thread(target=需要开启多线程的方法注意不要加括号, name=‘设置的线程名字(可选)‘, args=(传入方法的参数,可选如果只有一个参数 参数后要加逗号.))
threading.current_thread() # 返回当前进程的详细信息
threading.currentThread(): # 返回当前的线程变量。
threading.enumerate(): # 返回一个包含正在运行的线程的list。正在运行指线程启动后、结束前，不包括启动前和终止后的线程。
threading.activeCount(): # 返回正在运行的线程数量，len(threading.enumerate())有相同的结果。我们来看个例子吧:
import threading # 导入threading模块
def print_0_9(): # 我们定义一个输出1-10的函数
for i in range(10): # 我们用range生成 0-9这个数
# 我们使用threading.current_thread()获取进程的方法之上 再使用.getName()方法读取到进程的名字
print(‘这是线程{}:{}‘.format(threading.current_thread().getName(), i))
# 我们定义一个主函数
def main():
# 创建一个线程 设置线程名为 1 调用 print_0_9 这个函数 注意 函数名后面一定一定不要加括号
thread1 = threading.Thread(target=print_0_9, name=‘1‘)
thread2 = threading.Thread(target=print_0_9, name=‘2‘) # 再创建一个线程 设置线程名为 2
thread3 = threading.Thread(target=print_0_9, name=‘3‘) # 创建一个名为 3 的线程
thread1.start() # 启动线程 1
thread2.start() # 启动线程 2
thread3.start() # 启动线程 3
main() # 调用 main 函数
# 结果 你会看到三条交替运行的线程 有时会出现没有交替的情况,再跑一次程序就好了.Thread类方法
run(): # 用以表示线程活动的方法。
start(): # 启动线程活动。
join([time]): # 等待至线程中止。这阻塞调用线程直至线程的join() 方法被调用中止-正常退出或者抛出未处理的异常-或者是可选的超时发生。
isAlive(): # 返回线程是否活动的。
getName(): # 返回线程名。
setName(): # 设置线程名。使用继承类创建线程的方法:
import threading, time # 导入线程模块 时间模块(用来暂停程序)
def print_0_9(delay): # 定义一个输出函数 输出 0-9 个数 ,传入一个延迟 秒数
for i in range(10): # range生成 0-9 个数
time.sleep(delay) # 暂停程序 delay 秒
print(‘这是{}:{}‘.format(threading.current_thread().getName(), i)) # 打印出线程的名字 和range生成的值
class myThread(threading.Thread): # 定义一个 我的Thread类
def __init__(self, name, delay): # 初始化函数 传入进程名 延时秒数
# 二选一
threading.Thread.__init__(self) # 等效于super().__init__() # 父类初始化
# super().__init__() # 等效于threading.Thread.__init__(self) # 父类初始化
self.name = name
self.delay = delay
def run(self): # 继承Thread类 线程从这个方法开始
print_0_9(self.delay) # 线程 和传入的参数
if __name__ == ‘__main__‘: # 主函数入口
# 创建两个线程
thread1 = myThread(‘线程一‘, 0.5)
thread2 = myThread(‘线程二‘, 1)
# 开启线程
thread1.start()
thread2.start()
# 执行结果 两个线程交替运行打印出 0-9 的数值线程等待
import threading # 导入threading类
def m1(): # 定义了一个 m1 函数 输出 0-9 个数
for i in range(10):
print(threading.current_thread().getName(), i) # 打印线程名 由于没有设置线程名 会使用默认线程名字
if i == 5: # 在输出了 i == 5 之后线程等待
thread2 = threading.Thread(target=m2, name=‘线程二‘) # 创建线程二 插入 m2 函数
thread2.start() # 启动线程
thread2.join() # join线程 你可以尝试注释这句看看执行效果
def m2(): # 定义了一个 m2函数 输出 10-19个数
for i in range(10, 20):
print(threading.current_thread().getName(), i) # 打印线程名 和输出的值 i
m1() # 执行m1线程观察线程等待
# 输出结果 在输出了 5 之后 执行 m2 函数输出 m2里的值 输完之后在继续输出上一个线程的值.线程通信
线程共享同一个资源 可以使用globals或在方法外创建一个资源
import threading, time # 导入threading和time模块类
# 使用多线程, 模拟生活中的多窗口售票,这里演示四个窗口售票
listA = [x for x in range(1, 101)] # 定义一个票仓库 装 1-100号的票
def sell_ticket(): # 定义了一个售票的方法
while listA: # 当listA里有票的时候执行卖票
a = listA.pop() # 使用list的pop方法取出一张票赋值给a
time.sleep(0.1) # 等待0.1秒
print(‘窗口{}:卖出的票号为 {}‘.format(threading.current_thread().getName(), a)) # 打印当前线程名字 和 卖出的票号
else:
print(‘票卖完了‘) # 当listA里的票卖完后 执行本句
class myThread(threading.Thread): # 定义一个类 继承 threading.Thread
def __init__(self, name): # 初始化方法 传入线程名字
threading.Thread.__init__(self) # 父类初始化
# super().__init__() # 父类初始化
self.name = name
def run(self): # 父类继承过来的方法
sell_ticket() # 需要执行的 方法
if __name__ == ‘__main__‘: # 主函数入口
# 创建四个线程
thread1 = myThread(‘一‘) # 线程名 一
thread2 = myThread(‘二‘) # 线程名 二
thread3 = myThread(‘三‘) # 线程名 三
thread4 = myThread(‘四‘) # 线程名 四
# 开启线程
thread1.start() # 线程一开启
thread2.start() # 线程二开启
thread3.start() # 线程三开启
thread4.start() # 线程四开启标签：有一个 活动 hang enumerate start 运行 http 时间 函数
原文地址：https://www.cnblogs.com/Mrzhang3389/p/9601986.html
