Searched refs:_data_queue (Results 1 – 3 of 3) sorted by relevance
26 self._data_queue = None39 self._data_queue = Queue.Queue()71 self._data_queue.put((None, None))83 self._data_queue.put((refresh_period, timestamps))88 self._data_queue.put(e)93 ret = self._data_queue.get()
70 SmartPtr<ThreadPool::UserData> data = _pool->_data_queue.pop (); in loop()157 _data_queue.resume_pop (); in start()193 _data_queue.pause_pop (); in stop()194 _data_queue.clear (); in stop()242 if (!_data_queue.push (data)) in queue()248 _data_queue.erase (data); in queue()
79 SafeList<UserData> _data_queue; variable