python多线程之线程同步--锁

'''
线程同步---锁
不同线程操作某一个对象时，容易出现数据不完整或者不一致！
解决方案：加锁。在线程需要独占资源的时候，获取锁；
线程不需要独占资源的时候，释放锁，别的线程可以获取锁；

锁的目的：确保多个线程不会同时操作同一个资源，确保数据完整性和一致性；
同时，又保证了资源可以在不同线程之间轮转
锁的获取和释放的位置不合适，会引起线程阻塞或者死锁。
用到就获取，用完即释放。
'''
# encoding: utf-8

import threading
import time

a = [0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]

lock = threading.Lock()


class MyThread_Set1(threading.Thread):

    def __init__(self, thid=None, thname=None, step=0.1):
        # super().__init__(self)
        threading.Thread.__init__(self)
        self.step = step
        self.thid = thid
        self.thname = thname

    def run(self):
        print('%s开始' % self.thname)
        lock.acquire()  # 获取锁
        for i in range(len(a)):
            a[i] = 1
            time.sleep(0.1)

        print(a)
        lock.release()  # 释放锁
        print('%s结束' % self.thname)


class MyThread_Set2(threading.Thread):

    def __init__(self, thid=None, thname=None, step=0.1):
        threading.Thread.__init__(self)  # threading.Thread.__init__(self) 中的thread不要加()
        self.step = step
        self.thid = thid
        self.thname = thname

    def run(self):
        print('%s开始' % self.thname)
        lock.acquire()  # 获取锁
        for i in range(-1, -len(a)-1, -1):
            a[i] = 2
            time.sleep(0.1)

        print(a)
        lock.release()  # 释放锁
        print('%s结束' % self.thname)

print("主线程开始")
th1 = MyThread_Set1(thname='线程1')
th2 = MyThread_Set2(thname='线程2')

th2.start()
th1.start()

th1.join()
th2.join()
print("主线程结束")