如何解决Python ThreadPoolExecutor.map不适用于熊猫行
在我每次运行以下代码段时,ThreadPoolExecutor
不会执行该功能。终端上什么也没打印。
def get_route_data(itinerary):
route_id,src,dest,trip_type,onward_date_str,return_date_str,num_adult,num_child,num_infant,cabin_class = itinerary['ROUTE_ID'],itinerary['SRC'],itinerary['DEST'],itinerary['TRIP_TYPE'],itinerary['ONWARD_JOURNEY_DATE'],itinerary['RETURN_JOURNEY_DATE'],itineraryr['NUM_ADULT'],itinerary['NUM_CHILD'],itinerary['NUM_INFANT'],itinerary['CABIN_CLASS']
print(route_id,cabin_class)
print(threading.current_thread())
time.sleep(2)
def dummy_func(itenary_df,NUM_WORKERS):
itinerary_list = itenary_df.to_dict('records')
with concurrent.futures.ThreadPoolExecutor(max_workers=NUM_WORKERS) as executor:
executor.map(get_route_data,itinerary_list)
但是,如果我将get_route_data
更改为-
get_route_data(itinerary):
print(itinerary)
print(threading.current_thread())
time.sleep(2)
itinerary
被打印在控制台上。
我不明白为什么会这样以及如何解决。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。