+def parallel_delete(container, keys):
+ import Queue
+ from threading import Lock, Thread
+
+ keys = list(iter(keys))
+
+ q = Queue.Queue(16384)
+ l = Lock()
+
+ def deletion_task():
+ conn = AzureConnection()
+ while True:
+ k = q.get()
+ l.acquire()
+ print k
+ l.release()
+ conn.delete(container, k)
+ q.task_done()
+
+ for i in range(128):
+ t = Thread(target=deletion_task)
+ t.setDaemon(True)
+ t.start()
+
+ for k in keys:
+ q.put(k)
+ q.join()
+