支持的版本:当前 (17) / 16 / 15 / 14 / 13
开发版本:devel
不受支持的版本:12 / 11 / 10 / 9.6

15.1. 并行查询的工作原理 #

当优化器确定并行查询是特定查询的最快执行策略时,它将创建一个包含GatherGather Merge 节点的查询计划。这是一个简单的示例

EXPLAIN SELECT * FROM pgbench_accounts WHERE filler LIKE '%x%';
                                     QUERY PLAN
-------------------------------------------------------------------​------------------
 Gather  (cost=1000.00..217018.43 rows=1 width=97)
   Workers Planned: 2
   ->  Parallel Seq Scan on pgbench_accounts  (cost=0.00..216018.33 rows=1 width=97)
         Filter: (filler ~~ '%x%'::text)
(4 rows)

在所有情况下,GatherGather Merge 节点都将只有一个子计划,该子计划是将在并行中执行的计划部分。如果 GatherGather Merge 节点位于计划树的最顶端,则整个查询将并行执行。如果它位于计划树的某个其他位置,则只有它下面的计划部分将并行运行。在上面的示例中,查询仅访问一个表,因此除了 Gather 节点本身之外,只有一个计划节点;由于该计划节点是 Gather 节点的子节点,因此它将并行运行。

使用 EXPLAIN,你可以查看规划器选择的工作进程数量。在查询执行期间到达 Gather 节点时,实现用户会话的进程将请求数量等于规划器选择的工作进程数量的后台工作进程。规划器将考虑使用的后台工作进程数量最多限制为 max_parallel_workers_per_gather。任何时候可以存在的后台工作进程总数都受到 max_worker_processesmax_parallel_workers 的限制。因此,并行查询可能以比计划更少的工作进程运行,甚至根本没有工作进程。最佳计划可能取决于可用的工作进程数量,因此这可能会导致较差的查询性能。如果这种情况频繁发生,请考虑增加 max_worker_processesmax_parallel_workers 以便可以同时运行更多工作进程,或者减少 max_parallel_workers_per_gather 以便规划器请求更少的工作进程。

为给定并行查询成功启动的每个后台工作进程都将执行计划的并行部分。领导者也将执行计划的该部分,但它还有额外的责任:它还必须读取工作进程生成的所有元组。当计划的并行部分仅生成少量元组时,领导者的行为通常很像一个额外的工作进程,从而加快查询执行速度。相反,当计划的并行部分生成大量元组时,领导者可能几乎完全忙于读取工作进程生成的元组,并执行 Gather 节点或 Gather Merge 节点级别之上的计划节点所需的任何进一步处理步骤。在这种情况下,领导者将很少执行计划并行部分的工作。

当计划并行部分顶部的节点是 Gather Merge 而不是 Gather 时,这表示执行计划并行部分的每个进程都按排序顺序生成元组,并且领导者正在执行保留顺序的合并。相反,Gather 以任何方便的顺序从工作进程读取元组,从而破坏可能存在的任何排序顺序。

提交更正

如果您发现文档中的任何内容不正确、与您使用特定功能的经验不符或需要进一步澄清,请使用此表单报告文档问题。