multiprocessing_trial.py

import time
import pickle
import multiprocessing as mp
from multiprocessing import Manager

def my_worker(result):
    name = mp.current_process().name
    print(name, 'Starting')
    result.append(name+' Starting')
    time.sleep(1)
    print(name, 'Exiting')
    result.append(name+' Exiting')

def my_service(result):
    name = mp.current_process().name
    print(name, 'Starting')
    result.append(name+' Starting')
    time.sleep(0.1)
    print(name, 'Exiting')
    result.append(name+' Exiting')

if __name__ == '__main__':
	with Manager() as manager:
		result = manager.list()
		worker_list = []

		for i in range(1):
			worker = mp.Process(
				name='my_worker_'+str(i),
				target=my_worker,
				args = (result,)
			)
			service = mp.Process(
				name='my_service_'+str(i),
				target=my_service,
				args = (result,)
			)

			worker_list.append(worker)
			worker_list.append(service)

		for worker_ in worker_list:
			worker_.start()

		for worker in worker_list:
			worker.join()

	
		print(len(result))
		print(result)
		pickle.dump(list(result), open('result.pkl', 'wb'))