在 TParallel.For 中使用 SetCurrentDir 和 WinExec32AndWait 会跳过一些迭代

Question

我对 Tparallel.for 中的迭代次数有疑问。 我有 100 个文件夹，每个文件夹中都有一个要运行的文件（run.bat）。 运行后在文件夹中创建 out.txt 文件。当我使用 Tparalle.for 进行 100 次迭代时，我随机收到 90 到 98 个 out.txt，而它是 100。 我的代码如下（Delphi XE7）：

TParallel.For(1, 100, procedure(i: integer)
    begin
      SetCurrentDir(path + '\test\' + IntToStr(i));
      WinExec32AndWait(PChar('run.bat'), 0);
    end);

Answer 1

进程工作目录是进程的单个值。您期望每个任务都有自己的私有副本，但这根本不是工作目录的操作方式。在更专业的术语中，共享进程范围的工作目录存在数据竞争。由于创建子进程时的竞争，它们继承了父进程的工作目录，但由于竞争，一些子进程继承了为不同子进程准备的工作目录。这是并行编程所犯的经典错误之一。

通过避免使用父进程工作目录来解决这个问题。根本不要修改它。而是在创建它们时将工作目录传递给每个子进程。这可以使用CreateProcess 或ShellExecuteEx 非常简单地完成。您的 WinExec32AndWait 函数可能需要修改以接受工作目录参数。

这通过确保为每个不同的子进程创建工作目录的单独副本来解决问题。

Answer 2

setcurrentdir 当然不是多线程！如果 2 个线程同时将当前目录设置为 xxx 怎么办？ :)

改为

Tparallel.for(1,100.procedure(i:integer)
begin
  winexec32andwait(pchar(path+'\test\'+inttostr(i) + '\run.bat'),0);
end);