Python如何实现条件变量同步

import threading, time

from random import randint

class Producer(threading.Thread):

    def run(self):

        global L

        while True:

            val = randint(0, 100)

            print('生产者', self.name, ':Append'+str(val),L)

            if lock_con.acquire():

                L.append(val)

                lock_con.notify()

                lock_con.release()

            time.sleep(3)

class Consumer(threading.Thread):

    def run(self):

        global L

        while True:

            lock_con.acquire()

            if len(L) == 0:

                lock_con.wait()

            print('消费者', self.name, ":Delete" + str(L[0]), L)

            del L[0]

            lock_con.release()

            time.sleep(0.25)

if __name__ == "__main__":

    L = []

    lock_con = threading.Condition()

    threads = []

    for i in range(5):

        threads.append(Producer())

    threads.append(Consumer())

    for t in threads:

        t.start()

    for t in threads:

        t.join()

    print('---- end ----')

生产者 Thread-1 :Append63 []

生产者 Thread-2 :Append66 [63]

生产者 Thread-3 :Append20 [63, 66]

生产者 Thread-4 :Append83 [63, 66, 20]

生产者 Thread-5 :Append2 [63, 66, 20, 83]

生产者 Thread-4 :Append26 []

消费者 Thread-6 :Delete26 [26]

生产者 Thread-2 :Append21 []

生产者 Thread-3 :Append71 [21]

生产者 Thread-1 :Append19 [21, 71]

生产者 Thread-5 :Append100 [21, 71, 19]

生产者 Thread-1 :Append96 []

消费者 Thread-6 :Delete96 [96]

........