Searched refs:queue (Results 1 – 25 of 90) sorted by relevance
1234
18 import queue117 q = queue.Queue()217 except queue.Empty:221 raise queue.Empty(msg)265 except queue.Empty:281 raise queue.Empty(msg)321 raise queue.Empty(msg)337 except queue.Empty:352 self._event_dict[event_name] = queue.Queue()441 except (queue.Empty, KeyError):[all …]
33 private val queue = ArrayBlockingQueue<Packet<T>>(capacity) constant41 queue.put(Packet(data)) in add()47 queue.put(Packet(null)) in close()53 val packet = queue.take() in next()
17 import queue58 except queue.Empty:90 q = queue.Queue()103 except queue.Empty:146 except queue.Empty:
17 import queue150 except queue.Empty:182 except queue.Empty:
17 import queue100 except queue.Empty:
21 import queue53 except queue.Empty:101 except queue.Empty:140 except queue.Empty:182 except queue.Empty:220 except queue.Empty:281 except queue.Empty:
29 import queue66 except queue.Empty:129 except queue.Empty:167 except queue.Empty:262 except queue.Empty:305 except queue.Empty:359 except queue.Empty:403 except queue.Empty:
29 import queue
19 import queue104 except queue.Empty as e:113 except queue.Empty as e:122 except queue.Empty as e:132 except queue.Empty as e:
29 import queue328 except queue.Empty:343 except queue.Empty:360 except queue.Empty:
17 import queue125 except queue.Empty:211 except queue.Empty:289 except queue.Empty:304 except queue.Empty:406 except queue.Empty:513 except queue.Empty:529 except queue.Empty:548 except queue.Empty:564 except queue.Empty:[all …]
278 queue = Queue()280 args=(self.audio_params['duration'], queue))297 audio_captured = queue.get()331 queue = Queue()333 args=(self.audio_params['duration'], queue))352 audio_captured = queue.get()
142 queue = Queue()144 args=(self.audio_params['duration'],queue))159 audio_captured = queue.get()
18 import queue144 except queue.Empty as error:196 except queue.Empty as error:254 except queue.Empty as error:391 except queue.Empty as error:428 except queue.Empty as error:
18 import queue247 except queue.Empty as error:296 except queue.Empty as error:351 except queue.Empty as error:412 except queue.Empty as error:495 except queue.Empty as error:516 except queue.Empty as error:534 except queue.Empty as error:911 except queue.Empty as error:1053 except queue.Empty as error:
18 import queue119 except queue.Empty:
21 import queue74 except queue.Empty:91 except queue.Empty:99 except queue.Empty:
18 import queue51 except queue.Empty:72 except queue.Empty:468 except queue.Empty:
16 import queue209 sq = queue.Queue()210 cq = queue.Queue()
17 import queue77 except queue.Empty:
16 import queue155 except queue.Empty:
19 import queue115 except queue.Empty:
17 import queue216 def __init__(self, queue_generator=queue.Queue):
20 from queue import Empty
32 import queue109 except queue.Empty: