miner_thread.py

import logging
import threading
import time
import utils.shell as shell

class MinerThread(threading.Thread):
    def __init__(self, alg):
        threading.Thread.__init__(self)
        self.alg = alg
        self.active = False
      
    def run(self):
        logger = logging.getLogger()
        print ("Starting " + self.name)
        self.active = True

        # in case process fails, run again until thread is marked as inactive by parent
        while self.active == True:
            params = self.alg.getParams()
            print("Starting new thread: ", " ".join(params))
            p = shell.run(params)
                
            while(True):
                retcode = p.poll() #returns None while subprocess is running
                line = p.stdout.readline()
                str_line = "\033[0m[%s]%s" % (self.alg.__class__.__name__, line.decode("utf-8"))
                logger.info(str_line.strip())
            
                if not self.active:
                    p.terminate()
                    logger.info("Close signal sent")
                    time.sleep(5)

                if(retcode is not None):
                    logger.info("Miner processed finished")
                    break

            # kill zombie processes or still active
            shell.reset()