multiprocessing3.py

multiprocessing3.py

import multiprocessing
import time

numbers = range(100000, 1000000, 10000)
lock = multiprocessing.Lock()


def task(number):
    global lock
    print(f"Executing new Task with process {multiprocessing.current_process().pid}")

    result = 0
    for i in range(number):
        result = result + i

    lock.acquire()
    try:
        print(f"Result: {result}")
        print(f"Task Executed with process {multiprocessing.current_process().pid}")

    finally:
        lock.release()


def main():
    executor = multiprocessing.Pool(8)
    executor.map(task, numbers)
    executor.close()


if __name__ == "__main__":
    start_time = time.time()
    main()

    print("\n\nCOMPLETE\n--- Took %s seconds ---" % (time.time() - start_time))
    
    exit(0)