将数据帧传递给线程
passing a dataframe to a thread
在一个函数中,我创建了一个名为 resamp_df 的本地数据框。我正在尝试将此本地数据帧传递给线程函数作为 运行 某些算法的参数。这是我的代码:
主要功能
if readyForOrder:
order_thread = threading.Thread(target=order_management, name='thread1', args=resamp_df)
order_thread.start()
线程函数
def order_management(df):
global readyForOrder, order_id, order_id_counter, ltp
if df.shape[0] >= 3:
readyForOrder = False
old_ltp = df.iat[-2, 0]
new_ltp = df.iat[-1, 0]
但我的线程不是 运行。它会产生以下错误:
TypeError: order_management() takes 1 positional argument but 7 were given
有什么建议可以让它发挥作用吗?
提前致谢
以元组形式传入参数
args=(resamp_df, )
在一个函数中,我创建了一个名为 resamp_df 的本地数据框。我正在尝试将此本地数据帧传递给线程函数作为 运行 某些算法的参数。这是我的代码:
主要功能
if readyForOrder:
order_thread = threading.Thread(target=order_management, name='thread1', args=resamp_df)
order_thread.start()
线程函数
def order_management(df):
global readyForOrder, order_id, order_id_counter, ltp
if df.shape[0] >= 3:
readyForOrder = False
old_ltp = df.iat[-2, 0]
new_ltp = df.iat[-1, 0]
但我的线程不是 运行。它会产生以下错误:
TypeError: order_management() takes 1 positional argument but 7 were given
有什么建议可以让它发挥作用吗?
提前致谢
以元组形式传入参数
args=(resamp_df, )