2019-08-17 总结(多线程安全)

一. 线程间数据分享

情况一: 在子线程中使用主线程中的数据
# 总结: 数据的存储跟线程无关;一个进程中的数据在多个线程中可以直接用
 list1 = [1, 2, 3]


 def func1():
    list1.append(100)

 def func2():
     list1[0] = 'hello'


 t1 = Thread(target=func1)
 t2 = Thread(target=func2)
 t1.start()
 t2.start()

 t1.join()
 t2.join()
 print(list1)    # ['hello', 2, 3, 100]
情况2: 在子线程中使用子线程中产生的数据
def func1():
    global list1
    list1 = [1, 2, 3]


def func2():
    t = Thread(target=func1)
    t.start()
    print(list1)


t1 = Thread(target=func2)
t1.start()

二. 数据分享安全问题

"""
获取锁对象
获取数据
数操作完成后
释放锁对象

注意: 使用锁的时候保证一个数据对应一把锁
"""


class Account:
    """银行账号类"""
    def __init__(self, name, tel, balance, bank='招商银行'):
        self.bank = bank
        self.card_number = '6233392838382383'
        self.name = name
        self.tel = tel
        self.balance = balance
        self.lock = Lock()    # 1.创建锁(保证一个数据一把锁)

    def save_money(self, amount):
        print('=====开始存钱!======')
        # 2.使用锁
        self.lock.acquire()
        # 获取余额
        bl = self.balance
        # print('存钱余额1:',bl)
        sleep(2)
        self.balance = bl + amount
        # 3.释放锁
        self.lock.release()
        # print('存钱余额2:', self.balance)
        print('=====存钱结束!======')


    def draw_money(self, amount):
        print('=====开始取钱!======')
        self.lock.acquire()
        bl = self.balance
        # print('取钱余额1:', bl)
        if bl < amount:
            print('余额不足!')
            print('=====取钱结束======')
            return
        sleep(3)
        self.balance = bl - amount
        self.lock.release()
        # print('取钱余额2:', self.balance)
        print('=====取钱结束======')


account = Account('余婷', '153000782', 10000)

t1 = Thread(target=account.save_money, args=(20000,))
t2 = Thread(target=account.draw_money, args=(5000,))
t1.start()
t2.start()
t1.join()
t2.join()
print(account.balance)


account2 = Account('小明', '23782738738', 1000

三. 线程锁的使用

from threading import *
from time import sleep


list1 = [1, 2, 3]
lock = Lock()

def func1():
    lock.acquire()
    global list1
    list2 = list1[:]
    sleep(3)
    list2.append(100)
    list1 = list2[:]
    lock.release()


def func2():
    lock.acquire()
    global list1
    list2 = list1[:]
    sleep(3)
    list2.remove(2)
    list1 = list2[:]
    lock.release()


t1 = Thread(target=func1)
t2 = Thread(target=func2)
t1.start()
t2.start()
t1.join()
t2.join()
print(list1)
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • 本文主要讲了java中多线程的使用方法、线程同步、线程数据传递、线程状态及相应的一些线程函数用法、概述等。 首先讲...
    李欣阳阅读 7,206评论 1 15
  • Java多线程学习 [-] 一扩展javalangThread类 二实现javalangRunnable接口 三T...
    影驰阅读 8,102评论 1 18
  • 引用自多线程编程指南应用程序里面多个线程的存在引发了多个执行线程安全访问资源的潜在问题。两个线程同时修改同一资源有...
    Mitchell阅读 6,112评论 1 7
  • 林炳文Evankaka原创作品。转载自http://blog.csdn.net/evankaka 本文主要讲了ja...
    ccq_inori阅读 3,897评论 0 4
  •   一个任务通常就是一个程序,每个运行中的程序就是一个进程。当一个程序运行时,内部可能包含了多个顺序执行流,每个顺...
    OmaiMoon阅读 5,665评论 0 12

友情链接更多精彩内容