Блог

Что заблокировано в приведенном ниже коде, когда другие потоки запускаются раньше, почему код может использовать lock.acquire и снять эту блокировку? Так что же делает замок?

Что я хочу выразить, так это то, что блокировка основного потока, код для того, чтобы текст выглядел упорядоченным, я могу понять инстинктивно, а не логически. Может быть, мне не хватает некоторых знаний, касающихся потоковой передачи.

 import threading
import sys
import time
import pdb


def showfoo(n):
    for _ in range(n):
        lockpython.acquire()  # 获取对方的锁，释放自己的锁
        print('foo',end="")
        sys.stdout.flush()  # 释放缓冲区

        lockfoo.release()
        time.sleep(1)


def showbar(n):
    for _ in range(n):
        lockfoo.acquire()  # 获取对方的锁，释放自己的锁
        print('bar',end="")
        sys.stdout.flush()  # 释放缓冲区
        lockbar.release()
        time.sleep(1)
def showpython(n):
    for _ in range(n):
        lockbar.acquire()  # 获取对方的锁，释放自己的锁
        print('python',end="")
        sys.stdout.flush()  # 释放缓冲区
        lockpython.release()
        time.sleep(1)

if __name__ == '__main__':
    lockfoo = threading.Lock()  # 定义3个互斥锁
    lockbar = threading.Lock()
    lockpython = threading.Lock()
    n = int(input())
    t1 = threading.Thread(target=showfoo, args=[n])  # 定义3个线程
    t2 = threading.Thread(target=showbar, args=[n])
    t3 = threading.Thread(target=showpython, args=[n])
    lockfoo.acquire()  # 先锁住foo,bar锁，保证先打印foo
    lockbar.acquire()

    t1.start()
    t2.start()
    t3.start()
 

• все три потока запускаются
• showbar и сделайте showpython паузу на первой итерации своих циклов for
  • они приостанавливаются, потому что lock.acquire() блокируется до тех пор, пока блокировки не будут сняты, и эти блокировки были получены в основном потоке до их запуска.
• showfoo получает блокировку; что-то делает; затем освобождает другую блокировку
  • это позволяет одному из других потоков получить блокировку; что-то сделать; освободить другую блокировку.

Способ, которым вы разработали получение и освобождение блокировки, приводит к последовательному запуску потоков.