线程锁和队列

古城微笑少年丶 2022-05-18 09:34 258阅读 0赞

## 线程锁: ##

当有一个数据有多个线程都可以对其进行修改的时候,任何一个线程  
改变它都会被其他线程造成影响,如果我们某一个线程在使用完之前,其他线程  
不能对其修改,就需要对这个线程增加一个线程锁

join方法，是等待这个线程执行完毕后才会继续执行之后的语句。每一个线程都要有一个join，否则就不会等待这个线程执行完毕。

count = 0
    def get_money(money):
        global count
        money += money
        money += money
        money -= money
    #创建一个线程锁对象
    lock = threading.Lock()
    def lock_thread(money):
        #加锁
        lock.acquire()
        time.sleep(random.randint(1,3))
        print('当前线程为',threading.current_thread().name)
        get_money(money)
        time.sleep(random.randint(1, 3))
        print('当前线程为', threading.current_thread().name)
        #解锁
        lock.release()
    # 主线程  开辟一个分线程
    thread1 = threading.Thread(target=lock_thread,name='thread1',args=(1000,))
    thread2 = threading.Thread(target=lock_thread,name='thread2',args=(2000,))
    thread1.start()#2
    thread2.start()#3
    print('hello world')
    
    thread1.join()
    thread2.join()

join注重的整体,线程1没有执行完,线程2不能执行  
lock注重的是局部,某一个变量没有用完,其他线程不能使用

## 线程队列: ##

import queue
    #创建一个线程队列
    # 队列:FIFO first in first out  先进先出
    q = queue.Queue()
    for i in range(5):
        #将内容放入到线程队列中
        q.put(i)
    while not q.empty():
        # get得到
        print(q.get())
    # LIFO last in  forst out 后进先出
    p = queue.LifoQueue()
    for i in range(5):
        p.put(i)
    while not p.empty():
        print(p.get())

### 线程类的方法： ###

start ：线程准备就绪，等待CPU调度

setName ：为线程设置名称

getName ：获取线程名称

setDaemon：设置守护线程，设为True就是守护线程。默认False

join ：逐个执行每个线程，执行完毕后继续往下执行

run ：线程被cpu调度后自动执行线程对象的run方法

threading.current\_thread ： 查看当前的线程名

threading.active\_count ： 查看活动线程的数量