FilesExpand file tree

 master

/

p_queue.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

20 lines (15 loc) · 522 Bytes

 master

/

p_queue.py

Copy path

Top

File metadata and controls

• Code
• Blame

20 lines (15 loc) · 522 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

import queue

import threading

message_queue = queue.Queue(10)

def producer(i):

print('queue put {}'.format(i))

message_queue.put(i, block=True, timeout=2) # block:当队列满时是否阻塞 timeout:阻塞多久还满就报错

def consumer(i):

msg = message_queue.get(block=True, timeout=2)

print('queue get: {}'.format(msg))

for i in range(12):

t = threading.Thread(target=producer, args=(i,))

t.start()

for i in range(10):

t = threading.Thread(target=consumer, args=(i,))

t.start()