import glob
import numpy as np
import os
-import Queue
+import queue
import random
import scipy
from scipy import misc
# Start prefetching thread
# self.prefetch_queue = Queue.Queue(maxsize=prefetch_size)
- self.prefetch_queue = Queue.PriorityQueue(maxsize=prefetch_size)
+ self.prefetch_queue = queue.PriorityQueue(maxsize=prefetch_size)
for k in range(num_workers):
t = threading.Thread(target=prefetch_job,
args=(self.load_fn, self.prefetch_queue, self.data_list,