Davidmh_

Untitled

Mar 3rd, 2014
165
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.76 KB | None | 0 0
  1. def save_wavelet(q, path):
  2.     file = tables.open_file(path, 'w')
  3.     while True:
  4.         val = q.get()
  5.         if val is None:
  6.             break
  7.         W, chan, mz = val
  8.         # Guardando...
  9.         q.task_done()
  10.  
  11.     print 'Flushing wavelets and ready to close.'
  12.     q.task_done()
  13.     file.close()
  14.  
  15. def generate_wavelet(chan):
  16.     q.put((wavel, chan, mz))
  17.  
  18.  
  19. q = multiprocessing.JoinableQueue()
  20. saver = multiprocessing.Process(target=save_wavelet, args=(q, path))
  21. saver.start()
  22. Parallel(n_jobs=-1, verbose=3)(delayed(generate_wavelet)(channel)
  23.                                    for channel in profiles)
  24.                                    
  25. print 'Remaining', q.qsize(), '.',
  26. q.put(None)
  27. print 'Waiting for saving.'
  28. saver.join()
  29. saver.terminate()
Advertisement
Add Comment
Please, Sign In to add comment