Python ThreadPoolExecutor.map不适用于熊猫行

编程问答 2022-08-16

问题描述

在我每次运行以下代码段时，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 (将#修改为@）

multithreadingpandaspythonthreadpoolexecutor