0

Есть массив. Выступает он в роли некой "очереди". Нужно как то обрабатывать его в бесконечном цикле, но это нагружаемо, постоянно пытаться проверять, есть ли там что то, можно ли как то делать блокировку, пока в массиве не появится новый элемент, например как recv в сокетах?

2

1 ответ 1

1
import random, time, threading, queue

array = queue.Queue()  # Есть массив. Выступает он в роли некой "очереди".
results = queue.Queue()  # результ

def array_add_items():
    '''добавить эдементы в массив'''
    while True:
        for _ in range(random.randrange(10000)):
            array.put_nowait(random.randrange(10))
        print('len array(%s)' % array.qsize())
        time.sleep(random.randrange(5)) 

class WorkerThread(threading.Thread):
    '''Нужно как то обрабатывать его в бесконечном цикле'''
    def run(self):
        while True:
            try:
                # можно ли как то делать блокировку, пока в массиве не появится новый элемент
                item = array.get(timeout=2)
                results.put(-item)
                array.task_done()
            except queue.Empty:
                print('timeout=2 : array({i})->results({o})'.format(i=array.qsize(), o=results.qsize()))

if __name__ == '__main__':
    WorkerThread().start()
    array_add_items()

out:

len array(2042)
timeout=2 : array(0)->results(9860)
len array(1080)
len array(139)
timeout=2 : array(0)->results(12729)
len array(1273)
len array(1802)
len array(640)
timeout=2 : array(0)->results(32977)
len array(1137)

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.