indicator_acquire.py 文件源码

def run(self):
        result_list = []
        sql = None
        while True:
            self.lock.acquire()
            if not self.queue.empty():
                sql = self.queue.get()
                self.lock.release()
            else:
                self.lock.release()
                break
            stock_data = pd.read_sql_query(sql, con=self.db)
            stock_data = stock_data.set_index('datetime')
            result_list.append(stock_data)
            print "A stock has finished reading and {} stocks left".format(self.queue.qsize())

        self.lock.acquire()
        self.parent_list.extend(result_list)
        self.lock.release()
        self.db.close()