diff --git a/app/chain/site.py b/app/chain/site.py index 86e72b8e..0def3ea8 100644 --- a/app/chain/site.py +++ b/app/chain/site.py @@ -108,10 +108,6 @@ class SiteChain(ChainBase): "site_id": "*" }) - # 如果不是大内存模式,进行垃圾回收 - if not settings.BIG_MEMORY_MODE: - gc.collect() - return result def is_special_site(self, domain: str) -> bool: diff --git a/app/chain/subscribe.py b/app/chain/subscribe.py index 68f87818..6528dd80 100644 --- a/app/chain/subscribe.py +++ b/app/chain/subscribe.py @@ -1,5 +1,4 @@ import copy -import gc import json import random import threading @@ -284,7 +283,7 @@ class SubscribeChain(ChainBase): lock_acquired = False try: if lock_acquired := self._rlock.acquire( - blocking=True, timeout=self._LOCK_TIMOUT + blocking=True, timeout=self._LOCK_TIMOUT ): logger.debug(f"search lock acquired at {datetime.now()}") else: @@ -451,10 +450,6 @@ class SubscribeChain(ChainBase): self._rlock.release() logger.debug(f"search Lock released at {datetime.now()}") - # 如果不是大内存模式,进行垃圾回收 - if not settings.BIG_MEMORY_MODE: - gc.collect() - def update_subscribe_priority(self, subscribe: Subscribe, meta: MetaBase, mediainfo: MediaInfo, downloads: Optional[List[Context]]): """ @@ -526,9 +521,6 @@ class SubscribeChain(ChainBase): self.match( TorrentsChain().refresh(sites=sites) ) - # 如果不是大内存模式,进行垃圾回收 - if not settings.BIG_MEMORY_MODE: - gc.collect() @staticmethod def get_sub_sites(subscribe: Subscribe) -> List[int]: @@ -584,7 +576,7 @@ class SubscribeChain(ChainBase): lock_acquired = False try: if lock_acquired := self._rlock.acquire( - blocking=True, timeout=self._LOCK_TIMOUT + blocking=True, timeout=self._LOCK_TIMOUT ): logger.debug(f"match lock acquired at {datetime.now()}") else: @@ -829,7 +821,8 @@ class SubscribeChain(ChainBase): username=subscribe.username, save_path=subscribe.save_path, downloader=subscribe.downloader, - source=self.get_subscribe_source_keyword(subscribe) + source=self.get_subscribe_source_keyword( + subscribe) ) # 同步外部修改,更新订阅信息 diff --git a/app/chain/transfer.py b/app/chain/transfer.py index 76e4f23e..64ac71ed 100755 --- a/app/chain/transfer.py +++ b/app/chain/transfer.py @@ -910,10 +910,6 @@ class TransferChain(ChainBase, metaclass=Singleton): torrents.clear() del torrents - # 如果不是大内存模式,进行垃圾回收 - if not settings.BIG_MEMORY_MODE: - gc.collect() - # 结束 logger.info("所有下载器中下载完成的文件已整理完成") return True