Using mp.Pool instead of mp.Process

too_many_open_files.py

import multiprocessing as mp


def RunPrice(items, price):
    print("There is %s items, price is: %s" % (items, price))

def GetTargetItemsAndPrice(cursor):
    res = cursor.execute("SELECT DISTINCT items, price FROM SELLS")
    results = dict()
    with mp.Pool() as pool:
        for row in res.fetchall():
            args = (row[0], row[1])
            results[args] = pool.apply_async(RunPrice, args=args)
        for result in results.values():
            result.get()