ptrade的run_interval定时执行或者handle_data周期运行

在这几个函数里面打上标识，输出线程名字。


 
可以知道，他们是通过多线程触发的。 每一次运行的线程名字都不一样。
所以在里面操作一些共享变量的时候，最好加锁操作。
 
比如：

    def query_offset(self,start,count):

        sqlite_str = 'select code,open,current from {} limit {},{}'.format(self.table_name,start,count)

        cursor = self.db.cursor()

        with lock:

            try:

                cursor.execute(sqlite_str)

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                return cursor.fetchall()