'Wait for threadpool jobs to finish, then make a new pool.'

@utils.Synchronized
def Flush(self):

    self.pool.close()
    self.pool.join()
    self.pool = ThreadPool(config.CONFIG['CloudBigtable.threadpool_size'])
