我正在尝试并行化一个for循环。在每次迭代中,我将数据加载到dataframe中,执行一些操作并绘制一个图,然后将其保存为pdf。代码如下。 这是可行的,但在某些情况下它会崩溃。有时在80次迭代之后,有时在120次之后。我也得到了不同的错误消息(我不再有它们,但如果需要的话,可以尝试生成它们)。 你知道为什么会发生这种事吗?您能看到代码中有什么地方是错误的吗?def operation(ID):
load data into
我正在尝试用python并行化一些代码。串行运行我的代码大约需要24小时,然而,有一个for循环,其中每次迭代都独立于前一次迭代,所以这是并行化的理想情况。下面是我试图用代码实现的一个简单示例,from multiprocessing import Pool
for x inrange(0,2000)
y = sci.fft(data[x,:]
我用python在"range“循环中编写了一个" for”,并放置了一个"break“函数,让循环在特定的条件下结束。我需要为循环在中断点停止之前的迭代次数生成一个计数,但是我找不到正确的函数。我尝试创建range()值的列表,然后使用len()函数获取计数,但是range()列表无法识别break函数,它只是给出了直到范围结束的每次迭代的列表。for val in range(Nma