[bug] CPU load when idle about pympipool HOT 7 CLOSED

import sys

from mpi4py import MPI

from pympipool.shared.communication import (
    interface_connect,
    interface_send,
    interface_receive,
)
from pympipool.shared.backend import parse_arguments


def main(argument_lst=None):
    if argument_lst is None:
        argument_lst = sys.argv
    argument_dict = parse_arguments(argument_lst=argument_lst)
    if MPI.COMM_WORLD.rank == 0:
        context, socket = interface_connect(
            host=argument_dict["host"], port=argument_dict["zmqport"]
        )
    else:
        context, socket = None, None

    while True:
        if MPI.COMM_WORLD.rank == 0:
            input_dict = interface_receive(socket=socket)
        else:
            input_dict = None
        input_dict = MPI.COMM_WORLD.bcast(input_dict, root=0)
        if MPI.COMM_WORLD.rank == 0 and input_dict is not None:
            interface_send(socket=socket, result_dict={"result": input_dict})


if __name__ == "__main__":
    main(argument_lst=sys.argv)

import os
from pympipool import interface_bootup, interface_send, interface_receive

interface = interface_bootup(
    command_lst=["python", os.path.join(os.path.abspath("."), "reply.py")],
    cwd=None,
    cores=8,
    gpus_per_core=0,
    oversubscribe=False,
    enable_flux_backend=False,
    enable_slurm_backend=False,
    queue_adapter=None,
    queue_type=None,
    queue_adapter_kwargs=None,
)
interface.send_and_receive_dict(input_dict={"a": 1})

import sys

from pympipool.shared.communication import (
    interface_connect,
    interface_send,
    interface_receive,
)
from pympipool.shared.backend import parse_arguments


def main(argument_lst=None):
    if argument_lst is None:
        argument_lst = sys.argv
    argument_dict = parse_arguments(argument_lst=argument_lst)
    context, socket = interface_connect(
        host=argument_dict["host"], port=argument_dict["zmqport"]
    )

    while True:
        input_dict = interface_receive(socket=socket)
        interface_send(socket=socket, result_dict={"result": input_dict})


if __name__ == "__main__":
    main(argument_lst=sys.argv)