@ray.remote
def parallel1(a):
Gbr1 = ExponentialSmoothing(endog=series1['Price'],trend = True,damped_trend = True).fit(disp = False)
pr1 = list(Gbr1.forecast(136).values)[-1]
return pr1
@ray.remote
def parallel2(a):
Gbr2 = ExponentialSmoothing(endog=series2['Price'],trend = True,damped_trend = True).fit(disp = False)
pr2 = list(Gbr2.forecast(90).values)[-1]
return pr2
x_id = parallel1(-1).remote()
y_id = parallel2(-1).remote()
pr1,pr2 = ray.get([x_id,y_id])
试图并行化此代码,但出现错误:TypeError: Remote functions cannot be called directly. Instead of running '__main__.parallel1()', try '__main__.parallel1.remote()'
raylib是通过pip安装的
试一试
相关问题 更多 >
编程相关推荐