multi asyn processing fails: result = pool.map(x2p_job, generator()) goes to timeout about parametric-t-sne-in-keras HOT 3 OPEN

I checked a little further.

result = pool.map(x2p_job, generator())

def get(self, timeout=None):
in \anaconda3\lib\multiprocessing\pool.py(637)get()

from parametric-t-sne-in-keras.

Hi kamae, thank you for your interest in this repository.

I used multiprocessing library in this procedure, which allow us to easily write multi process computation. Its documentation is here. It might help you.

By the way, you seem to be using python 3 (by anaconda3). In this code, python 2.7 is used because I wrote this a long time ago. Thus, if you execute this code using python 2.7 and Keras 1.0.3, it may work well.

from parametric-t-sne-in-keras.

@kamae Hi Kamae, I remove the pool part and use for loop directly, which works for me.
The following for your reference.

    # pool = mp.Pool(n_jobs)
    # result = pool.map(x2p_job, generator())
    result = []
    for i in range(n):
        result.append(x2p_job([i, D[i], tol, logU]))

from parametric-t-sne-in-keras.