Function consumer

src/12/polling_multiple_thread_queues/pqueue.py:39–47

Consumer that reads data on multiple queues simultaneously

(queues)

    import time

    def consumer(queues):
        '''
        Consumer that reads data on multiple queues simultaneously
        '''
        while True:
            can_read, _, _ = select.select(queues,[],[])
            for r in can_read:
                item = r.get()
                print('Got:', item)

    q1 = PollableQueue()
    q2 = PollableQueue()