Method get

towhee/runtime/data_queue.py:108–121

(self)

        return True

    def get(self) -> Optional[List]:
        with self._not_empty:
            while self._size <= 0 and not self._sealed:
                self._not_empty.wait()

            if self._size <= 0:
                return None

            ret = []
            for col in self._data:
                ret.append(col.get())
            self._size -= 1
            self._not_full.notify()
            return ret

    def get_dict(self, cols: List[str] = None) -> Optional[Dict]:
        data = self.get()