| | |
|---|
| | | if current_info is not None: |
|---|
| | | _start_time = time.time() |
|---|
| | | strategic_thread_manager(current_info) |
|---|
| | | use_time_list.append(time.time() - _start_time) |
|---|
| | | use_time_list.append((time.time() - _start_time, current_info[0])) |
|---|
| | | except Exception as error: |
|---|
| | | logging.exception(error) |
|---|
| | | # print("异常：", current_info) |
|---|
| | |
|---|
| | | if use_time > 0.5: |
|---|
| | | # 记录超过1s的数据 |
|---|
| | | async_log_util.info(logger_debug, "L1数据处理时间统计：thread-{} 总计用时-{} 平均耗时-{} 最大耗时-{}", |
|---|
| | | tool.get_thread_id(), use_time, sum(use_time_list) / len(use_time_list), |
|---|
| | | max(use_time_list)) |
|---|
| | | tool.get_thread_id(), use_time, sum([x[0] for x in use_time_list]) / len(use_time_list), |
|---|
| | | max(use_time_list, key=lambda e: e[0])) |
|---|
| | | |
|---|
| | | # @dask.delayed |
|---|
| | | # def batch_process_current_infos(fs): |
|---|
