day 18 总结

day 18 多线程(thread)

Date:2019.5.9

内容纲要:

线程.png

一、线程

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.单线程下载两个电影

  在一个线程中下载两个电影:时间是两个电影下载的总和

2.线程模块

1)current_thread函数 - 获取当前线程
print(threading.current_thread())
2) Thread类

  Thread类的对象就是线程,所以需要子线程就创建这个类的对象
Thread(target,args,kwargs)
target - 函数, 需要在当前创建的子线程中去调用的函数
args/kwargs - 调用target中的函数需要的实参列表

# a.创建线程对象
t1 = threading.Thread(target=download, args=('复联5',))
# t1 = threading.Thread(target=download, kwargs={'film_name': '复联5'})
t2 = threading.Thread(target=download, args=('007',))

# b.开始执行子线程中的任务: 线程对象.start()
"""
通过start方法,在子线程中去调用target对应的函数
"""
t1.start()
t2.start()

二、线程的创建和使用

1.创建自己的线程类

1)声明一个类继承Thread
2)实现run方法,这个方法中的人物就是需要在子线程中执行的任务
3)用子类直接创建线程对象
4)通过start去执行子线程中的任务
  注意:一个进程中如果有多个线程,程序会在所有的线程都结束的时候才结束,发生异常崩溃其实崩溃的是线程,

class DownloadThread(Thread):

    def __init__(self, film_name):
        super().__init__()
        self.film_name = film_name

    def run(self):
        # print(current_thread())
        # print('在子线程中执行的代码')
        print('开始下载:%s' % self.film_name, datetime.now())
        time.sleep(2)
        print('结束下载:%s' % self.film_name, datetime.now())


t1 = DownloadThread('哥斯拉2')
t2 = DownloadThread('大侦探皮卡丘')
t1.start()
t2.start()
# t1.run()        # 不能直接调用run方法,因为这样调用不会在子线程中执行任务

三、join

1.join

  如果希望某个任务是在某个线程结束后才执行,那就将这个任务的带放在对应线程对象调用join方法的后面

class DownloadThread(Thread):

    def __init__(self, name, time):
        super().__init__()
        self.name = name
        self.time = time

    def run(self):
        print('开始下载:%s' % self.name, datetime.now())
        time.sleep(2)
        print('结束下载:%s' % self.name, datetime.now())


t1 = DownloadThread('沉默的羔羊', 5)
t2 = DownloadThread('权利的游戏', 7)


t2.start()



t2.join()
print('电影下载完成,用时%d秒')

t1.start()
t1.join()
print('电影下载完成,用时%d秒')

四、线程数据及锁的使用

1.线程数据的混乱

  数据安全问题:当多个线程同时对一个数据进行读写操作的时候,可能会出现一个线程刚把数据读出来还没来的及写进去,另一个线程进行读操作而出现的

2.锁的使用:数据混乱解决 - 加锁

1)保证每个数据对应一个锁对象
2)操作数据前加锁,数据操作完成后释放锁

class Acount(Thread):

    def __init__(self, name, tel, balance = 50):
        super().__init__()
        self.name = name
        self.tel = tel
        self.balance = balance
        # 关联一个锁对象
        self.lock = Lock()

    def save_money(self, money):
        print('开始存钱')
        # 加锁
        self.lock.acquire()
        value = self.balance
        time.sleep(4)
        self.balance = value + money
        print('存钱成功!%.2f' % self.balance)
        # 释放锁
        self.lock.release()

    def draw_money(self, money):
        print('开始取钱')
        # 加锁
        self.lock.acquire()
        value = self.balance
        time.sleep(4)
        if value < money:
            print('取钱失败!余额不足')
            return
        self.balance = value - money
        print('取钱成功:%.2f' % self.balance)
        # 释放锁
        self.lock.release()

acount = Acount('李卓然', '18648606874', 10000)

t1 = Thread(target=acount.save_money, args=(1000,))
t2 = Thread(target=acount.draw_money, args=(500,))

t1.start()
t2.start()


print('======================')
share_data = 1000
lock = Lock()


def add_data(value):
    lock.acquire()
    global share_data
    old_data = share_data
    time.sleep(4)
    share_data = old_data + value
    lock.release()
    print(value)


t1 = Thread(target=add_data, args=(200,))
t2 = Thread(target=add_data, args=(300,))

t1.start()
t2.start()
t1.join()
t2.join()

print(share_data)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。