Source code for deephyper.evaluator.storage._shared_memory_storage

from multiprocessing.managers import BaseManager

from deephyper.evaluator.storage._memory_storage import MemoryStorage


BaseManager.register("MemoryStorage", MemoryStorage)




def SharedMemoryStorage():
    """Creates a server process managing a MemoryStorage class.

    This also provides Proxy classes to processes to which it is passed. This
    function, is made to be used in combination
    with :class:`deephyper.evaluator.ProcessPoolEvaluator`.
    """
    manager = BaseManager()
    manager.start()
    return manager.MemoryStorage()