Day18_学习总结

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）操作数据前加锁，数据操作完成后释放锁