FilesExpand file tree

 master

/

queue.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

31 lines (24 loc) · 561 Bytes

 master

/

queue.py

Copy path

Top

File metadata and controls

• Code
• Blame

31 lines (24 loc) · 561 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

21

22

23

24

25

26

27

28

29

30

31

import time

import Queue

import logging

import threading

logging.basicConfig(

level=logging.INFO,

format='%(threadName)s: %(message)s')

log = logging.getLogger()

q = Queue.Queue()

def producer():

for x in range(10):

time.sleep(0.5)

log.info('>>> %s', x)

q.put(x)

def consumer():

while True:

x = q.get()

log.info('<<< %s', x)

t_producer = threading.Thread(target=producer)

t_consumer = threading.Thread(target=consumer)

t_consumer.setDaemon(True)

t_producer.start()

time.sleep(2)

t_consumer.start()