# -*- coding:utf-8 -*-

 import time

 import pymongo

 from threading import Thread

 from Queue import Queue

 start  = time.time()

 f = open("ids.txt")

 q = Queue()

 def work():

     connection=pymongo.Connection('127.0.0.1',27017)

     db = connection.pps_legual_cache

     c = db.episode1

     while 1:

         line = q.get()

         print c.find_one(int(line))

         q.task_done()

 for i in range(5):

     t = Thread(target=work)

     t.setDaemon(True)

     t.start()

 for line in f.readlines():

     q.put(int(line))

 q.join()

 end = time.time()

 print end-start