From b957db6d6fe644f82717f77b47cb71f5f04e0165 Mon Sep 17 00:00:00 2001 From: MoonGem <34537029+MoonGem@users.noreply.github.com> Date: Sun, 25 Mar 2018 06:18:46 -0500 Subject: [PATCH] Keeps threads full --- scripts/random.py | 34 ++++++++++++++++++++++++++++++++++ 1 file changed, 34 insertions(+) create mode 100644 scripts/random.py diff --git a/scripts/random.py b/scripts/random.py new file mode 100644 index 000000000..91fb2de3a --- /dev/null +++ b/scripts/random.py @@ -0,0 +1,34 @@ +#!/usr/bin/env python3 +import os +import multiprocessing +from itertools import zip_longest +import subprocess +import re +PROC_COUNT = multiprocessing.cpu_count() - 1 +cwd = os.getcwd() +print(cwd) + + +limit = multiprocessing.cpu_count() - 1 +WORK_DIR = os.path.join( + os.path.sep, + os.path.abspath(os.path.dirname(__file__)), + '..', 'freqtrade', 'main.py' +) + +# Spawn workers +command = [ + 'python3.6', + WORK_DIR, + 'backtesting', +] +global current +current = 0 + +while True: + def Run(command): + global current + processes = [subprocess.Popen(command) for i in range(PROC_COUNT)] + for proc in processes: + wait = proc.communicate() + data = Run(command)