Method shutdown

python/graphscope/nx/classes/cache.py:244–255

(self)

            yield from self.node_id_cache

    def shutdown(self):
        for _, future in self.futures.items():
            if future is not None:
                future.cancel()

        for _, future in self.futures.items():
            if future is not None:
                try:
                    future.result()
                except concurrent.futures.CancelledError:
                    pass
                future = None

    def shutdown_executor(self):
        self.executor.shutdown(wait=True)