Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def save_wavelet(q, path):
- file = tables.open_file(path, 'w')
- while True:
- val = q.get()
- if val is None:
- break
- W, chan, mz = val
- # Guardando...
- q.task_done()
- print 'Flushing wavelets and ready to close.'
- q.task_done()
- file.close()
- def generate_wavelet(chan):
- q.put((wavel, chan, mz))
- q = multiprocessing.JoinableQueue()
- saver = multiprocessing.Process(target=save_wavelet, args=(q, path))
- saver.start()
- Parallel(n_jobs=-1, verbose=3)(delayed(generate_wavelet)(channel)
- for channel in profiles)
- print 'Remaining', q.qsize(), '.',
- q.put(None)
- print 'Waiting for saving.'
- saver.join()
- saver.terminate()
Advertisement
Add Comment
Please, Sign In to add comment