A task processor abstraction wrapping multiprocessing.Process

process.py

import os
import sys
from typing import *
import multiprocessing

class Process(multiprocessing.Process):
	def __init__(self, id: int, task_queue: Iterable, results: Iterable):
		super(Process, self).__init__()
		self.id = id
		self.task_queue = task_queue
		self.results = results

	def run(self):
		while True:
			t = self.task_queue.get()
			self.task_queue.task_done()
			if not t:
				break
			self.results.put(t.run())
		return