WOLFRAM

Wolfram 语言与系统 参考资料中心
Wolfram 语言首页 »

ParallelEvaluate
✖
ParallelEvaluate

Unsupported in Public Cloud

✖

在所有并行内核上计算表达式 expr，并返回得到结果的列表.

✖
ParallelEvaluate[expr,kernel]

在指定的并行内核上计算 expr.

✖
ParallelEvaluate[expr,{ker1,ker2,…}]

在并行内核 keri 上计算 expr.

✖
ParallelEvaluate[expr,kernels,h]

在返回结果之前将标头 h 封装在结果周围.

更多信息和选项

  • ParallelEvaluate 有属性 HoldFirst.
  • 可用 KernelObject（由 Kernels[] 返回）或内核的整数 ID（由 $KernelID 返回）指定内核. 也可以使用 All.
  • 以下属性也可用于选择所有运行内核的一个子集：
  • All所有内核
    "CloudKernels"所有云内核
    "LinkKernels"所有链接的内核
    "LocalKernels"本地运行的所有内核
    "LWGKernels"所有 LightweightGrid 内核
    "OneKernelPerMachine"每个不同的机器都有一个内核
    "RemoteKernels"远程机器上的所有内核
    "SshKernels"所有 SSH 内核
    "WSTPServerKernels"所有 WSTPServer 内核
  • ParallelEvaluate 的 DistributedContexts 选项指定在开始计算之前，自动将哪些出现在 expr 中的符号的定义分配到所有可用的内核上.
  • 默认情况下，DistributedContexts:>$DistributedContexts，同时 $DistributedContexts:=$Context，会将所有符号按当前情形下的定义进行分配，但不会分配从程序包中来的符号的定义.

范例

打开所有单元关闭所有单元

基本范例  (1)常见实例总结

获取每个并行内核唯一的 ID 号：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-8eopg7
Out[1]=1

获取每个并行内核的系统进程 ID：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-1mod0y
Out[2]=2

范围  (9)标准用法实例范围调查

使用 ParallelEvaluate 在所有并行内核上执行初始化：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-c3tuei
Out[1]=1

在所有并行内核上，产生局部函数的定义：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-dnw7g
Out[1]=1
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-fxbs6d
Out[2]=2

获取所有并行内核的局部属性：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-cndzq0
Out[1]=1

从单个内核获取一个局部属性：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-3971z2
Out[2]=2

从源访问对于并行内核局部的数据：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-hsxj77
Out[1]=1

把在并行内核上计算得到的结果分别保存在本地的唯一的文件中：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-mp4gpg
Out[1]=1

证明文件已经被写入：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-xi39zs
Out[2]=2

防止对子内核返回的结果在本地重新进行运算：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-h5c2hz
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-e2t6by
Out[2]=2
In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-9msa83
Out[3]=3

在每台机器上只在一个内核上进行计算：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-holabc
Out[1]=1

只在所有本地内核上进行运算：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-vxsxks
Out[1]=1

仅在所有 LightweightGrid 内核上进行计算：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-0ug25a
Out[1]=1

推广和延伸  (2)推广和延伸使用的实例

指定一个内核对象或者内核 ID 查询的内核：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-sdk3y
Out[1]=1
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-c4yhw3
Out[2]=2
In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-3snez
Out[3]=3

查询一些内核：

In[4]:=4
✖
https://wolfram.com/xid/0g7ggpmjous-c86zvf
Out[4]=4

All 可用来指定所有可用内核：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-6q0lo7
Out[1]=1
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-x4icps
Out[2]=2

All 相当于 Kernels[]：

In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-fy11j9
Out[3]=3

选项  (5)各选项的常用值和功能

DistributedContexts  (5)

缺省情况下，自动分配当前情形下的定义：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-g9gh34
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-clbr3t
Out[2]=2

不要分配函数的任何定义：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-6xao0
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-kx0x4h
Out[2]=2

对出现在并行计算中所有情形下的所有符号分配定义：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-hu6d1y
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-s80e6
Out[2]=2

只分配在给定情形下的定义：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-yht7o
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-n7ym7a
Out[2]=2

把 DistributedContexts 选项的值恢复到缺省值：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-qkhgjy
Out[1]=1

应用  (4)用该函数可以解决的问题范例

把所有并行内核的属性列表：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-sg0liz

通过在所有并行内核上运行相同的代码，并行化一个蒙特卡罗模拟：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-2eqaxy
Out[1]=1

把所有的单个平均值组合起来，以得到一个更准确的整体结果：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-04c8wf
Out[2]=2

把大的中间结果保存在本地的每个并行内核上：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-njkl1d
Out[1]=1

使用本地保存的数据工作：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-likvlw
Out[2]=2

检查是否所有的多项式都是不可约的：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-gdfn96
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-mg8ls7
Out[2]=2

用于同步化的共享变量：

In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-czwvi2

在每个内核上运行一个搜索循环，直到计算退出：

In[4]:=4
✖
https://wolfram.com/xid/0g7ggpmjous-dsntjf

属性和关系  (5)函数的属性及与其他函数的关联

ParallelEvaluate 在每个子内核上执行相同的计算：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-3kiglo
Out[1]=1

Parallelize 把一个计算的每个部分分配到每个子内核：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-es2xyb
Out[2]=2

确定性的计算在每个并行内核上给出同样的结果：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-eb193p
Out[1]=1

涉及随机性的计算在每个并行内核上给出独立的结果：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-pvyama
Out[2]=2

通过设置 SeedRandom，产生相同的结果：

In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-w8bk4p
In[4]:=4
✖
https://wolfram.com/xid/0g7ggpmjous-rnao2l
Out[4]=4

每个并行内核具有不同的 ID，它可以用来使得表达式唯一：

In[5]:=5
✖
https://wolfram.com/xid/0g7ggpmjous-e807ei
Out[5]=5

DistributeDefinitions 使用 ParallelEvaluate 把定义传输给所有内核：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-ihim4b
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-fem2ri

一个显式的 ParallelEvaluate 执行同样的操作：

In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-dsbeg3
In[4]:=4
✖
https://wolfram.com/xid/0g7ggpmjous-i058rf
Out[4]=4

对于新的内核记录分配好的定义：

In[5]:=5
✖
https://wolfram.com/xid/0g7ggpmjous-isia9p

不记录 ParallelEvaluate 的效果：

In[6]:=6
✖
https://wolfram.com/xid/0g7ggpmjous-lpps4x
Out[6]=6

ParallelNeeds 使用 ParallelEvaluate 在所有并行内核上运行 Needs：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-gde7je
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-cddqo

另外，记录所有的使用，以使得新的内核也加载必须的程序包：

In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-dqm48f
In[4]:=4
✖
https://wolfram.com/xid/0g7ggpmjous-ehklot
Out[4]=4

ParallelEvaluate 自动分配使用的函数定义：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-ysr612
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-dzfz6p
Out[2]=2

可能存在的问题  (2)常见隐患和异常行为

副作用不能在不同的并行内核之间使用：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-vly9qf
Out[1]=1

使用一个共享变量来支持副作用：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-cf7cc7
In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-sdt1k
Out[3]=3
In[4]:=4
✖
https://wolfram.com/xid/0g7ggpmjous-d5nkmd
Out[4]=4

在用 ParallelEvaluate 进行定义时抑制定义的自动分配：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-mvqq9t
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-3vpez3
Out[2]=2
In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-mna4h7
Out[3]=3

巧妙范例  (2)奇妙或有趣的实例

求 使得 是素数，直到计算手动退出：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-gje3ls
In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-ddeli7
Out[2]=2

考虑到在许多不同的机器上有多个运行的内核：

In[1]:=1
✖
https://wolfram.com/xid/0g7ggpmjous-bhxewe
Out[1]=1

在每台机器上将一个资源函数仅在缓存中加载一次：

In[2]:=2
✖
https://wolfram.com/xid/0g7ggpmjous-6tizj3
Out[2]=2

在所有内核中使用资源函数：

In[3]:=3
✖
https://wolfram.com/xid/0g7ggpmjous-wo4ge
Out[3]=3
Wolfram Research (2008)，ParallelEvaluate，Wolfram 语言函数，https://reference.wolfram.com/language/ref/ParallelEvaluate.html （更新于 2020 年）.
✖
Wolfram Research (2008)，ParallelEvaluate，Wolfram 语言函数，https://reference.wolfram.com/language/ref/ParallelEvaluate.html （更新于 2020 年）.

文本

Wolfram Research (2008)，ParallelEvaluate，Wolfram 语言函数，https://reference.wolfram.com/language/ref/ParallelEvaluate.html （更新于 2020 年）.

✖
Wolfram Research (2008)，ParallelEvaluate，Wolfram 语言函数，https://reference.wolfram.com/language/ref/ParallelEvaluate.html （更新于 2020 年）.

CMS

Wolfram 语言. 2008. "ParallelEvaluate." Wolfram 语言与系统参考资料中心. Wolfram Research. 最新版本 2020. https://reference.wolfram.com/language/ref/ParallelEvaluate.html.

✖
Wolfram 语言. 2008. "ParallelEvaluate." Wolfram 语言与系统参考资料中心. Wolfram Research. 最新版本 2020. https://reference.wolfram.com/language/ref/ParallelEvaluate.html.

APA

Wolfram 语言. (2008). ParallelEvaluate. Wolfram 语言与系统参考资料中心. 追溯自 https://reference.wolfram.com/language/ref/ParallelEvaluate.html 年

✖
Wolfram 语言. (2008). ParallelEvaluate. Wolfram 语言与系统参考资料中心. 追溯自 https://reference.wolfram.com/language/ref/ParallelEvaluate.html 年

BibTeX

@misc{reference.wolfram_2025_parallelevaluate, author="Wolfram Research", title="{ParallelEvaluate}", year="2020", howpublished="\url{https://reference.wolfram.com/language/ref/ParallelEvaluate.html}", note=[Accessed: 30-March-2025 ]}

✖
@misc{reference.wolfram_2025_parallelevaluate, author="Wolfram Research", title="{ParallelEvaluate}", year="2020", howpublished="\url{https://reference.wolfram.com/language/ref/ParallelEvaluate.html}", note=[Accessed: 30-March-2025 ]}

BibLaTeX

@online{reference.wolfram_2025_parallelevaluate, organization={Wolfram Research}, title={ParallelEvaluate}, year={2020}, url={https://reference.wolfram.com/language/ref/ParallelEvaluate.html}, note=[Accessed: 30-March-2025 ]}

✖
@online{reference.wolfram_2025_parallelevaluate, organization={Wolfram Research}, title={ParallelEvaluate}, year={2020}, url={https://reference.wolfram.com/language/ref/ParallelEvaluate.html}, note=[Accessed: 30-March-2025 ]}