Function _do_parallel_data_prefetch

code/dc_ldm/util.py:95–104

(func, Q, data, idx, idx_to_fn=False)

    return getattr(importlib.import_module(module, package=None), cls)

def _do_parallel_data_prefetch(func, Q, data, idx, idx_to_fn=False):
    # create dummy dataset instance

    # run prefetching
    if idx_to_fn:
        res = func(data, worker_id=idx)
    else:
        res = func(data)
    Q.put([idx, res])
    Q.put("Done")


def parallel_data_prefetch(