1 进程和线程
进程:进程就是操作系统中执行的一个程序,操作系统以进程为单位分配存储空间,每个进程都有自己的地址空间、数据栈以及其他用于跟踪进程执行的辅助数据
线程:一个进程还可以拥有多个并发的执行线索,简单的说就是拥有多个可以获得CPU调度的执行单元,这就是所谓的线程。每个进程默认都有一个线程,这个线程叫主线程;其他的线程都叫子线程
1.1 直接调用threading模块进行多线程操作
import time
from datetime import datetime
import threading
def download(film_name):
print('开始下载:%s' % film_name,datetime.now())
time.sleep(5)
print('%s下载完成' % film_name,datetime.now())
# 1、单线程下载两个电影
# # 在一个线程中下载两个电影:时间是两个电影下载的综合
# download('123')
# download('456')
# 2、线程模块
# 1)current_thread函数 -- 获取当前线程
print(threading.current_thread())
# 2)Thread类
# Thread类的对象就是线程,所以需要子线程就创建这个类的对象
# Thread(target,args,kwargs)
# target -- 函数,需要在当前创建的子线程中取调用的函数
# a.创建线程对象 -- 调用target中的函数需要的实参列表
t1 = threading.Thread(target=download, args=('123',))
t2 = threading.Thread(target=download, args=('456',))
# b.开始执行子线程中的任务:线程对象.start()
# 通过start方法,在子线程中去调用target对应的函数
t1.start()
t2.start()
1.2 通过创建类进行多线程操作
import random
import time
from datetime import datetime
import threading
# 1、创建自己的线程类
'''
1)声明一个类继承Thread
2)实现润方法,这个方法中的任务就是需要在子线程中执行的任务
注意:一个进程中如果有多个线程,程序会在所有的线程都结束时才结束
发生异常崩溃其实崩溃的是线程
'''
class DownloadThread(threading.Thread):
def __init__(self, film_name):
super().__init__()
self.film_name =film_name
def run(self):
print('开始下载:%s' % self.film_name,datetime.now())
time.sleep(random.randint(5,10))
print('%s下载完成' % self.film_name,datetime.now())
# 3、用子类直接创建线程对象
t1 = DownloadThread('123')
t2 = DownloadThread('456')
#4、通过start去执行子线的中的任务
t1.start()
t2.start()
# t1.run() 不能直接调用run方法,因为这样不会再子线程中执行任务
1.3 join
如果希望某个人物是在某个线程结束后才执行,那就将这个人物的代码放在对应线程对象调用join方法的后面.
from threading import *
import time
from random import randint
class DownloadThread(Thread):
def __init__(self, name):
super().__init__()
self.name = name
self.time = 0
def run(self):
self.time = randint(5, 10)
print('开始下载%s' % self.name)
time.sleep(self.time)
print('%s下载结束,用时%s' % (self.name, self.time))
start = time.time()
t1 = DownloadThread('123')
t2 = DownloadThread('456')
t1.start()
t2.start()
t1.join()
t2.join()
end = time.time()
print('下载结束,总共用时%s' % (end-start))
1.4 锁的使用
1.问题
当多个线程同时对一个数据进行读写操作,可能会出现一个线程刚把数据读出来还没来得及写进去,另一个线程进行读操作而出现的数据安全问题
2.解决 -- 加锁
1)保证每个数据对应一个锁对象
2)操作数据前加锁,数据操作完成后释放锁