Update threader.py

This commit is contained in:
abdallaEG
2021-05-02 04:28:03 +02:00
committed by GitHub
parent 068a991074
commit f62119b8f8

View File

@@ -1,9 +1,10 @@
import subprocess
import os
from concurrent.futures import ThreadPoolExecutor
from multiprocessing import Event
from tqdm import tqdm
shell = os.getenv("SHELL") if os.getenv("SHELL") else "/bin/sh"
class Task(object):
def __init__(self, command):
@@ -49,7 +50,8 @@ class Task(object):
def _run_task(self, t=False):
s = subprocess.Popen(self.task, shell=True,
stdout=subprocess.PIPE,
encoding="utf-8")
encoding="utf-8",
executable=shell)
out, _ = s.communicate()
if out != "":