lc-thomas/multitasker.py

## multitasker.py
from multiprocessing import Process
import asyncio as aio
import coloredlogs, logging
import time

PROCESSES = 2
COROUTINES_PER_PROCESS = 5

class Multitasker:
  def __init__(self):
    logger.info('Running multitasker')

  def run(self):
    logger.info(f'Spawning {PROCESSES} processes')
    processes = [Process(target=self.process, daemon=True) for p in range(PROCESSES)]
    [p.start() for p in processes]
    [p.join() for p in processes]

  def process(self):
    logger.info(f"  - process started, starting {COROUTINES_PER_PROCESS} coroutines")
    loop = aio.new_event_loop()
    aio.set_event_loop(loop)
    tasks = [aio.ensure_future(self.main_coroutine(n_coroutine)) for n_coroutine in range(COROUTINES_PER_PROCESS)]
    loop.run_until_complete(aio.wait(tasks))

  async def main_coroutine(self, n_coroutine):
    logger.info(f'    - running coroutine {n_coroutine} waiting {n_coroutine + 1} secs')
    await aio.sleep(n_coroutine + 1)
    logger.info(f'    - done')


if __name__ == '__main__':
  logger = logging.getLogger('log')
  logger.setLevel(logging.DEBUG)
  coloredlogs.install(logger=logger, fmt='%(asctime)s [%(process)d] %(levelname)s %(message)s')

  mt = Multitasker()
  mt.run()
	from multiprocessing import Process
	import asyncio as aio
	import coloredlogs, logging
	import time

	PROCESSES = 2
	COROUTINES_PER_PROCESS = 5

	class Multitasker:
	def __init__(self):
	logger.info('Running multitasker')

	def run(self):
	logger.info(f'Spawning {PROCESSES} processes')
	processes = [Process(target=self.process, daemon=True) for p in range(PROCESSES)]
	[p.start() for p in processes]
	[p.join() for p in processes]

	def process(self):
	logger.info(f" - process started, starting {COROUTINES_PER_PROCESS} coroutines")
	loop = aio.new_event_loop()
	aio.set_event_loop(loop)
	tasks = [aio.ensure_future(self.main_coroutine(n_coroutine)) for n_coroutine in range(COROUTINES_PER_PROCESS)]
	loop.run_until_complete(aio.wait(tasks))

	async def main_coroutine(self, n_coroutine):
	logger.info(f' - running coroutine {n_coroutine} waiting {n_coroutine + 1} secs')
	await aio.sleep(n_coroutine + 1)
	logger.info(f' - done')


	if __name__ == '__main__':
	logger = logging.getLogger('log')
	logger.setLevel(logging.DEBUG)
	coloredlogs.install(logger=logger, fmt='%(asctime)s [%(process)d] %(levelname)s %(message)s')

	mt = Multitasker()
	mt.run()