python__系统 : 线程

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

线程之间,全局变量可以共享,但是局部变量依然是不共享的,线程的创建方式: threading.Thread(),还可以定义一个类继承Thread,重写他的run方法,具体和进程的写法一样.

那么,线程之前全局变量共享,如果两个线程同时修改一个全局变量,就会有一些麻烦,所以需要用到互斥锁:

from threading import Thread, Lock

import time

g_num = 

def test1():

    global g_num

    mutex.acquire()           <------------------------------

    for i in range():

        g_num +=

    mutex.release()          <-----------------------------

    print(g_num)

def test2():

    global g_num

    mutex.acquire()       <----------------------

    for i in range():

        g_num +=

    mutex.release()       <------------------------

    print(g_num)

mutex = Lock()

t1 = Thread(target=test1)

t1.start()

t2 = Thread(target=test2)

t2.start()

>>>

Lock() 是创建一把锁,用acquire() 的方式加锁 , release() 的方式解锁. 如果一个线程对一个变量加锁,剩下的线程就只能在等待,解锁之后用通知(还有一种耗费资源的方式是轮询) 的方式给等待的线程传递信息,锁已经解开.

需要注意应该避免死锁, Lock 的 acquire() 里面有两个参数 blocking=True 默认是True 如果已经上锁,那么就一直在这等,等到锁解开为止,也就是堵塞. 改成False 的话如果已上锁那么就跳过这个加锁操作,所以一般搭配 if 使用加锁成功返回值True. 还有一个参数timeout=-1 ,默认-1.就是延迟,如果改成正数,那么就会在等待多少秒之后才放弃加锁.

同步 : 协同步调,按预定的先后次序运行. 异步:不确定什么时候运行.

threading.local() 创建一个对象,里面可以保存一些类似字典一样的参数,如 localVal = threading.local()

localVal.val = name这条语句可以储存一个变量到当前线程，如果在另外一个线程里面再次对localVal.val进行赋值，

那么会在另外一个线程单独创建内存空间来存储，也就是说在不同的线程里面赋值不会覆盖之前的值，因为每个

线程里面都有一个单独的空间来保存这个数据,而且这个数据是隔离的，其他线程无法访问,就像这张图一样:

最后,生产者与消费者模型:

from queue import Queue

import time, threading

class Producer(threading.Thread):

    def run(self):

        global queue

        count =

        while True:

            if queue.qsize() < :

                for i in range():

                    count = count +

                    msg = '生成产品' + str(count)

                    queue.put(msg)

                    print(msg)

            time.sleep(0.5)

class Consumer(threading.Thread):

    def run(self):

        global queue

        while True:

            if queue.qsize() > :

                for i in range():

                    msg = self.name + '消费了' + queue.get()

                    print(msg)

            time.sleep(0.5)

if __name__ == '__main__':

    queue = Queue()

    for i in range():

        queue.put('初始产品' + str(i))

    for i in range():

        p = Producer()

        p.start()

    for i in range():

        c = Consumer()

        c.start()