一.多线程基础
每个进程默认都有一条线程,这个线程叫主线程。其他线程叫子线程
threading模块中Thread的对象就是线程对象,当程序中需要子线程就创建Thread类的对象
import threading
from datetime import datetime
from time import sleep
def download(film_name):
# film_name = '魔童降世'
print('开始下载%s:%s' % (film_name, datetime.now()))
print(film_name, threading.current_thread())
sleep(5)
print('%s下载结束:%s' % (film_name, datetime.now()))
if __name__ == '__main__':
download('魔童降世')
download('扫毒2')
download('怦然心动')
# 1.创建线程对象
"""
Thread(target=None,args=()) - 创建并且返回一个子线程对象
target - 函数类型(function), 在线程启动的时候这个函数会在子线程中执行
args - 元祖,元祖中的元素就是target对应的函数在子线程中调用的时候传的实参
"""
t1 = threading.Thread(target=download, args=('魔童降世',))
t2 = threading.Thread(target=download, args=('扫毒2',))
t3 = threading.Thread(target=download, args=('怦然心动',))
print(threading.current_thread())
# 2.启动线程
"""
线程对象.start() - 让线程去执行线程中的任务
target(*args)
"""
t1.start()
t2.start()
t3.start()
二.线程之间的数据共享
数据的存储跟线程无关
1.创建锁对象:lock = Lock()
2.使用锁:lock.acquire()
3.数据操作完成后释放锁对象:lock.release()
注意:每个对象需要创建一把锁,每个数据需要加锁和开锁
三.锁的使用
from threading import *
from time import sleep
list1 = [1, 2, 3]
list1_lock = Lock()
def func1():
list1_lock.acquire()
global list1
list2 = list1[:]
sleep(2)
list2.append(100)
list1 = list2[:]
list1_lock.release()
def func2():
list1_lock.acquire()
global list1
list2 = list1[:]
sleep(2)
list2.remove(2)
list1 = list2[:]
list1_lock.release()
t1 = Thread(target=func1)
t2 = Thread(target=func2)
t1.start()
t2.start()
t1.join()
t2.join()
print(list1)