Python如何实现队列的同步实现

import queue

d = queue.Queue()

d.put('1')

d.put('2')

d.put('3')

print(d.get())

print(d.get())

print(d.get())

print(d.get())

print(d.get(0))

1

2

3

queue.Empty

import threading, time

li = [1, 2, 3, 4, 5]

def pri():

    while li:

        a = li [-1]

        print(a)

        time.sleep(1)

        try:

            li.remove(a)

        except:

            print('-----', a)

t1 = threading.Thread(target=pri, args=())

t1.start()

t2 = threading.Thread(target=pri, args=())

t2.start()

5

5

4

----- 5

4

3

----- 4

3

2

----- 3

2

1

----- 2

1

----- 1

import threading, queue

from time import sleep

from random import randint

class Production(threading.Thread):

    def run(self):

        while True:

            r = randint(0, 100)

            q.put(r)

            print("生产出来 %s 号包子" %r)

            sleep(1)

class Proces(threading.Thread):

    def run(self):

        while True:

            re = q.get()

            print('吃掉 %s号包子' %re)

if __name__ == '__main__':

    q = queue.Queue(10)

    threads = [Production(),Production(),Production(),Proces()]

    for t in threads:

        t.start()

生产出来 94 号包子

生产出来 13 号包子

生产出来 79 号包子

吃掉 94号包子

吃掉 13号包子

吃掉 79号包子

生产出来 43 号包子

吃掉 43号包子

生产出来 32 号包子

吃掉 32号包子

......