Echo/fcb_photo_review
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

开启多线程

Browse Source
This commit is contained in:
liuyebo
2024-07-06 17:01:03 +08:00
parent 249430246d
commit 85c00b242b
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
photo_review/photo_review.py
View File

@@ -1,3 +1,4 @@
import concurrent.futures
import json
import logging
import math
@@ -337,7 +338,7 @@ def settlement_task(pk_phhd, settlement_list):
def discharge_task(pk_phhd, discharge_record):
discharge_record_ie_result = request_ie_result(DISCHARGE_IE, discharge_record)
discharge_record_ie_result = information_extraction(DISCHARGE_IE, discharge_record)
discharge_data = {
"pk_phhd": pk_phhd,
"hospital": handle_hospital(get_best_value_in_keys(discharge_record_ie_result, HOSPITAL)),
@@ -378,7 +379,7 @@ def discharge_task(pk_phhd, discharge_record):
def cost_task(pk_phhd, cost_list):
cost_list_ie_result = request_ie_result(COST_IE, cost_list)
cost_list_ie_result = information_extraction(COST_IE, cost_list)
cost_data = {
"pk_phhd": pk_phhd,
"name": handle_name(get_best_value_in_keys(cost_list_ie_result, PATIENT_NAME)),
@@ -415,14 +416,14 @@ def photo_review(pk_phhd):
elif phrec.cRectype == "4":
cost_list.append(phrec)
# with concurrent.futures.ThreadPoolExecutor() as executor:
# executor.submit(settlement_task, pk_phhd, settlement_list)
# executor.submit(discharge_task, pk_phhd, discharge_record)
# # executor.submit(settlement_and_discharge_task, pk_phhd, settlement_list, discharge_record)
# executor.submit(cost_task, pk_phhd, cost_list)
settlement_task(pk_phhd, settlement_list)
discharge_task(pk_phhd, discharge_record)
cost_task(pk_phhd, cost_list)
with concurrent.futures.ThreadPoolExecutor() as executor:
executor.submit(settlement_task, pk_phhd, settlement_list)
executor.submit(discharge_task, pk_phhd, discharge_record)
# executor.submit(settlement_and_discharge_task, pk_phhd, settlement_list, discharge_record)
executor.submit(cost_task, pk_phhd, cost_list)
# settlement_task(pk_phhd, settlement_list)
# discharge_task(pk_phhd, discharge_record)
# cost_task(pk_phhd, cost_list)
def main():