Почему идёт закрытие канала в multiprocessing?

Question

[Space Around]

Использую multiprocessing в python, запускаю программу, она выполняет всё необходимое и завершается такой ошибкой:

Traceback (most recent call last):
  File ".\src\controller.py", line 139, in <module>
    main()
  File ".\src\controller.py", line 128, in main
    r2.send({"action": "add_items_con"})
  File "C:\Users\Kulic\AppData\Local\Programs\Python\Python38-32\lib\multiprocessing\connection.py", line 206, in send
    self._send_bytes(_ForkingPickler.dumps(obj))
  File "C:\Users\Kulic\AppData\Local\Programs\Python\Python38-32\lib\multiprocessing\connection.py", line 280, in _send_bytes
    ov, err = _winapi.WriteFile(self._handle, buf, overlapped=True)
BrokenPipeError: [WinError 232] Идет закрытие канала

1. Если подобная ошибка выскакивает после завершения программы это критично
   
2. По какой причине может выскакивать подобная ошибка?
   
3. Какие существуют варианты её решения? В документации по этому поводу ничего не сказанной, также читал, что подобная ошибка связанна с нехваткой оперативной памяти, но я сильно сомневаюсь, что 4ГБ RAM не хватает на запуск всего двух процессов, это родительский и дочерний
   

Так же нашёл в документации вот это:

Close the Process object, releasing all resources associated with it. ValueError is raised if the underlying process is still running. Once close() returns successfully, most other methods and attributes of the Process object will raise ValueError.

возможно, это нормально что высвечивается эта ошибка?

Comments

[Roman K]

Код в студию

[Space Around]

controller:

readers = []
    parsing_success = False
    brwsr_prepare_success = False

    r, w = Pipe(duplex=True)
    readers.append(r)
    p = Process(target=parsing_fnc, args=(w, config['parser']['interval'], config['parser']['attempts_max'], config['parser']['url'], config['parser']['keyword'], config['deamon']['parser']))
    p.start()
    w.close()

    for i in range(browsers_count):
        r2, w2 = Pipe(duplex=True)
        readers.append(r2)
        if(config['proxy']['enable']):
            p2 = Process(target=executer_fnc, args=(w2, i+1, carts[i], users[i], payments[i], proxy_array[i], proxy_auth, config['deamon']['executer']))
        else:
            p2 = Process(target=executer_fnc, args=(w2, i+1, carts[i], users[i], payments[i], [], {}, config['deamon']['executer']))
        p2.start()
        w2.close()

    while readers:
        for r in wait(readers):
            try:
                msg = r.recv()

                if(msg['action'] == "start_browser_prsr"):
                    parsing_success = True

                if(msg['action'] == "error_conntection_prsr"):
                    print("error_conntection_prsr")

                if(msg['action'] == "browser_prepare_success_ex"):
                    brwsr_prepare_success = True

                if(msg['action'] == "success_buy_items"):
                    pass
                    # print("success_buy_items")

                if(parsing_success & brwsr_prepare_success):
                    try:
                        r2.send({"action": "add_items_con"})
                    except BrokenPipeError as e:
                        pass

            except EOFError:
                readers.remove(r)

executer:

def executer_fnc(w, index, cart_param = {}, user_param = {}, payment_param = {}, proxy_param = [], proxy_auth_param = {}, deamon_param = {}):
    # тут обработчик с action
    if(len(proxy_param) > 0):
        proxy = proxy_param
        proxy_auth = proxy_auth_param

    driver_tmp = executer_prepare_fnc(w, index)

    readers = []
    readers.append(w)

    while readers:
        for r in wait(readers, timeout = 300):
            try:
                msg = r.recv()

            except EOFError:
                readers.remove(r)
            else:
                if(msg['action'] == "add_items_con"):
                    if(deamon_param['enable']):

                        while True:
                            t1 = datetime.strptime(deamon_param['start']['time'], '%H:%M:%S')
                            t2 = datetime.strptime(datetime.now().strftime('%H:%M:%S'), '%H:%M:%S')

                            if((datetime.now().strftime('%H:%M:%S') == deamon_param['start']['time']) | (t1 < t2)):
                                # action
                                add_buy(index, driver_tmp, cart_param, user_param, payment_param)
                                break
                            time.sleep(1)

                    else:
                        add_buy(index, driver_tmp, cart_param, user_param, payment_param)

                    w.send({"action":"success_buy_items"})


                    w.close()
                    readers.remove(r)
                    bs_print3("STATUS", f"BROWSER {index}", f"closed", "GREEN", "PURPLE", "WHITE")

    pass

parser:

def parsing_fnc(w, interval_param, attempts_max_param, url_param, keyword_param, deamon_param = {}):

    if(deamon_param['enable']):

        while True:
            t1 = datetime.strptime(deamon_param['start']['time'], '%H:%M:%S')
            t2 = datetime.strptime(datetime.now().strftime('%H:%M:%S'), '%H:%M:%S')

            if((datetime.now().strftime('%H:%M:%S') == deamon_param['start']['time']) | (t1 < t2)):
                # action
                parcer_event(w, interval_param, attempts_max_param, url_param, keyword_param)
                break;
            time.sleep(1)
    else:
        parcer_event(w, interval_param, attempts_max_param, url_param, keyword_param)

    pass