(self, threadnum, callback, timeout=10)
| 442 | class threadpool: |
| 443 | |
| 444 | def __init__(self, threadnum, callback, timeout=10): |
| 445 | self.thread_count = self.thread_nums = threadnum |
| 446 | self.queue = queue.Queue() |
| 447 | con = httpcon(timeout=timeout) |
| 448 | self.hack = hackRequests(con) |
| 449 | self.isContinue = True |
| 450 | self.thread_count_lock = threading.Lock() |
| 451 | self._callback = callback |
| 452 | |
| 453 | def push(self, payload): |
| 454 | self.queue.put(payload) |
nothing calls this directly
no test coverage detected