aboutsummaryrefslogtreecommitdiff
path: root/main.py
diff options
context:
space:
mode:
authorGravatar Qetesh <4559341+Qetesh@users.noreply.github.com> 2024-08-19 22:51:28 +0800
committerGravatar Qetesh <4559341+Qetesh@users.noreply.github.com> 2024-08-19 22:51:28 +0800
commit722fbfc6849444a558d2362e4cfbc0ca27558ee5 (patch)
tree2df12e2c9953deef03167a3c9f436f72cc550da4 /main.py
parentff8e06f2d495497d111e45f368b6c3bb1f9088c1 (diff)
downloadminiflux-ai-722fbfc6849444a558d2362e4cfbc0ca27558ee5.tar.gz
miniflux-ai-722fbfc6849444a558d2362e4cfbc0ca27558ee5.tar.zst
miniflux-ai-722fbfc6849444a558d2362e4cfbc0ca27558ee5.zip
limit max_workers to 4v0.5.1
Diffstat (limited to 'main.py')
-rw-r--r--main.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/main.py b/main.py
index 79bad01..dc041b7 100644
--- a/main.py
+++ b/main.py
@@ -47,7 +47,7 @@ while True:
start_time = time.time()
print(time.strftime("%Y/%m/%d %H:%M:%S", time.localtime()), 'Fetched unread entries: ' + str(len(entries['entries']))) if len(entries['entries']) > 0 else print(time.strftime("%Y/%m/%d %H:%M:%S", time.localtime()), 'No new entries')
- with concurrent.futures.ThreadPoolExecutor() as executor:
+ with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
futures = [executor.submit(process_entry, i) for i in entries['entries']]
for future in concurrent.futures.as_completed(futures):
try: