adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Code clean-up

Browse Source
This commit is contained in:
MoonGem 2018-03-25 09:32:05 -05:00 committed by GitHub
parent 77ea47f32b
commit b63db679c1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
user_data/random/random.py
View File

@ -1,14 +1,11 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
import os import os
import multiprocessing import multiprocessing
from itertools import zip_longest
import subprocess import subprocess
import re import re
PROC_COUNT = multiprocessing.cpu_count() - 1 PROC_COUNT = multiprocessing.cpu_count() - 1
cwd = os.getcwd() cwd = os.getcwd()
print(cwd) print(cwd)
global procs
limit = 24
WORK_DIR = os.path.join( WORK_DIR = os.path.join(
os.path.sep, os.path.sep,
os.path.abspath(os.path.dirname(__file__)), os.path.abspath(os.path.dirname(__file__)),
@ -22,12 +19,13 @@ command = [
'backtesting', 'backtesting',
] ]
global current global current
global procs
current = 0 current = 0
procs = 0 procs = 0
DEVNULL = open(os.devnull, 'wb') DEVNULL = open(os.devnull, 'wb')
while True: while True:
while procs < 32: while procs < PROC_COUNT:
try: try:
procs + 1 procs + 1
proc = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE) proc = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)