astelm/tg-ws-proxy
1
0
Fork 0
mirror of https://github.com/Flowseal/tg-ws-proxy.git synced 2026-08-08 23:33:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

hard limit workers pool

Browse Source
This commit is contained in:
Flowseal
2026-07-31 14:20:58 +03:00
parent ecf3d6f3a1
commit 41e97c6a05
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/pool.py
+2 -1
View File
@@ -218,6 +218,7 @@ class _WsPool:
class _CfWorkerPool: class _CfWorkerPool:
WS_POOL_MAX_AGE = 100.0 WS_POOL_MAX_AGE = 100.0
PER_DC_LIMIT = 1
def __init__(self): def __init__(self):
self._idle: Dict[Tuple[int, str], deque] = {} self._idle: Dict[Tuple[int, str], deque] = {}
@@ -258,7 +259,7 @@ class _CfWorkerPool:
dc, worker_domain = key dc, worker_domain = key
try: try:
bucket = self._idle.setdefault(key, deque()) bucket = self._idle.setdefault(key, deque())
needed = proxy_config.pool_size - len(bucket) needed = min(proxy_config.pool_size - len(bucket), self.PER_DC_LIMIT)
if needed <= 0: if needed <= 0:
return return
tasks = [asyncio.create_task( tasks = [asyncio.create_task(