asdfthread.py

import threading

import random
import time
import sys
import os


class ASDFException(BaseException):

    def __init__(self, msg):
        super(ASDFException, self).__init__()
        self.msg = msg

    def __str__(self):
        return self.msg


class asdf(threading.Thread):

    def __init__(self, _id):
        super(asdf, self).__init__()
        self.trials = 0
        self._id = _id

    def run(self):
        i = 0
        while True:

            try:
                print('id : %d step : %d' % (self._id, i))
                time.sleep(self._id * random.randint(1, 10))
                raise KeyError('id : %d' % self._id)
            
            except BaseException as e:
                self.trials += 1
                print('%s trials %d' % (e, self.trials))

                if self.trials == 5:
                    os._exit(-1)
                                        
                    


if __name__ == '__main__':
    eee = []

    try:
        for i in range(5):
            
            eee.append(asdf(i + 1))
            eee[i].start()
    except ASDFException as e:
        print(e)