Python 多线程学习03

本是古典何须时尚 2022-08-18 00:46 118阅读 0赞

上篇说道 要用Lock 来解决 ，线程争抢的问题。  
于是我修改了代码：

#coding:utf8
    
    
    import threading,random
    import time
    
    class Cut(threading.Thread):
        def __init__(self,content):
            threading.Thread.__init__(self)
            self.content = content
    
    
        def run(self):
            global alock
    
            alock.acquire()
            while(len(content) > 0): 
                time.sleep(random.randrange(0,2))
                tmp = content.pop()
                print self.getName(), tmp 
            alock.release()
    
    
    if '__main__' == __name__:
    
        filename = "easy.txt"
        f = open(filename)
        content = f.read().split("\n")
        content = content[:-1]
        print content
    
        global alock
        alock = threading.Lock()
    
        workman = Cut(content)
        workman2 = Cut(content)
    
        workman.start()
        workman2.start()
    
    
        f.close()

在main中 定义了 alock 这个Lock变量，然后 获取 list长度，和 pop 操作两边进行 加锁和释放 ，来看运行结果。

[root@172.18.4.100 thread]# python work.py 
    ['0', '1', '2', '3', '4', '5', '6', '7', '8', '9']
    Thread-1 9
    Thread-1 8
    Thread-1 7
    Thread-1 6
    Thread-1 5
    Thread-1 4
    Thread-1 3
    Thread-1 2
    Thread-1 1
    Thread-1 0
    [root@172.18.4.100 thread]#

这个结果，确实没有竞争了， 但线程2 完全没有存在感。  
回去查看代码，发现 线程1 在获取了锁之后，直到全部处理完，才把锁放开了， 所以线程2 根本没有表现的机会。

这就是用锁用的过猛了。 锁不应该用这么大的范围，否则， 你的多线程，又变成单线程了。

下面再修改程序 ，把跟 list 相关的操作分离出来 。

代码如下：

#coding:utf8
    
    
    import threading,random
    import time
    
    class Cut(threading.Thread):
        def __init__(self,content):
            threading.Thread.__init__(self)
            self.content = content
    
    
        def run(self):
            global alock
    
            while True:
                alock.acquire()
                length = len(content)
                if length >0:
                    tmp = content.pop()
                    alock.release()
                else:
                    alock.release()
                    break
    
                time.sleep(random.randrange(0,2))
                print self.getName(), tmp
    
    
    if '__main__' == __name__:
    
        filename = "easy.txt"
        f = open(filename)
        content = f.read().split("\n")
        content = content[:-1]
        print content
    
        global alock
        alock = threading.Lock()
    
        workman = Cut(content)
        workman2 = Cut(content)
    
        workman.start()
        workman2.start()
    
    
        f.close()

运行的结果像下面这样：

[root@2.8.4.100 thread]# python work.py 
    ['0', '1', '2', '3', '4', '5', '6', '7', '8', '9']
    Thread-1 9
    Thread-2 7
    Thread-1 8
    Thread-1 5
    Thread-2 6
    Thread-1 4
    Thread-2 3
    Thread-2 1
    Thread-2 0
    Thread-1 2
    [root@2.8.4.100 thread]#

这次结果就没有报错，而且也可以两个线程一起运行，我多试了几次，也都没有异常。  
观察输出，发现，这次的结果并不是 9,8,7,6,5.. 这样顺序打印出来的， 这是因为每个线程会有一个随机的处理时间 。 比较符合实际的情况。

没有漏掉，也没有重复， 符合要求。

我随后试了 启动4个线程来工作的情况

#coding:utf8
    
    
    import threading,random
    import time
    
    class Cut(threading.Thread):
        def __init__(self,content):
            threading.Thread.__init__(self)
            self.content = content
    
    
        def run(self):
            global alock
    
            while True:
                alock.acquire()
                length = len(content)
                if length >0:
                    tmp = content.pop()
                    alock.release()
                else:
                    alock.release()
                    break
    
                time.sleep(random.randrange(0,2))
                print self.getName(), tmp
    
    
    if '__main__' == __name__:
    
        filename = "easy.txt"
        f = open(filename)
        content = f.read().split("\n")
        content = content[:-1]
        print content
    
        global alock
        alock = threading.Lock()
    
        workman = Cut(content)
        workman2 = Cut(content)
        workman3 = Cut(content)
        workman4 = Cut(content)
    
        workman.start()
        workman2.start()
        workman3.start()
        workman4.start()
    
    
        f.close()

程序运行结果为：

[root@2.8.4.100 thread]# python work.py 
    ['0', '1', '2', '3', '4', '5', '6', '7', '8', '9']
    Thread-1 9
    Thread-2 7
    Thread-2 5
    Thread-2 4
    Thread-4 2
    Thread-4 1
    Thread-4 0
    Thread-1 8
    Thread-3 6
    Thread-2 3
    [root@2.8.4.100 thread]#

上面的结果，符合要求。 当线程较多时， 不必像我一样定义这么多变量， 应该使用list之类的数据结构。