SyncBatchNorm#
- class torch.nn.modules.batchnorm.SyncBatchNorm(num_features, eps=1e-05, momentum=0.1, affine=True, track_running_stats=True, process_group=None, device=None, dtype=None)[source]#
对 N 维输入应用批归一化。
N 维输入是 [N-2] 维输入的 mini-batch(具有额外的通道维度),如论文 Batch Normalization: Accelerating Deep Network Training by Reducing Internal Covariate Shift 中所述。
均值和标准差是按维度在所有同属一个进程组的 mini-batch 中计算的。 和 是可学习的参数向量,大小为 C(其中 C 是输入的大小)。默认情况下, 的元素从 中采样,而 的元素被设置为 0。标准差是通过有偏估计量计算的,等同于 torch.var(input, unbiased=False)。
同样,默认情况下,在训练期间,该层会保持其计算出的均值和方差的运行估计,这些估计随后用于评估期间的归一化。运行估计使用默认的
momentum
值 0.1 进行保持。如果将
track_running_stats
设置为False
,则该层将不再保持运行估计,而是会在评估期间也使用批统计数据。注意
此
momentum
参数与优化器类中使用的参数以及动量的传统概念不同。数学上,这里运行统计量的更新规则是 , 其中 是估计的统计量, 是新观察到的值。由于 Batch Normalization 是针对
C
维度中的每个通道进行的,因此在(N, +)
切片上计算统计量,因此通常称之为 Volumetric Batch Normalization 或 Spatio-temporal Batch Normalization。目前
SyncBatchNorm
只支持单 GPU/进程 的DistributedDataParallel
(DDP)。在将网络包装到 DDP 之前,使用torch.nn.SyncBatchNorm.convert_sync_batchnorm()
将BatchNorm*D
层转换为SyncBatchNorm
。- 参数
num_features (int) – ,来自期望输入大小为 的输入。
eps (float) – 为了数值稳定性添加到分母中的值。默认值:
1e-5
momentum (Optional[float]) – 用于 running_mean 和 running_var 计算的值。可以设置为
None
以进行累积移动平均(即简单平均)。默认值:0.1affine (bool) – 一个布尔值,如果设置为
True
,则该模块具有可学习的仿射参数。默认值:True
track_running_stats (bool) – 一个布尔值,当设置为
True
时,此模块会跟踪运行均值和方差,当设置为False
时,此模块不会跟踪此类统计量,并将统计量缓冲区running_mean
和running_var
初始化为None
。当这些缓冲区为None
时,此模块在训练和评估模式下始终使用 batch 统计量。默认值:True
process_group (Optional[Any]) – 统计量的同步在每个进程组内部单独进行。默认行为是在整个 world(所有进程)之间进行同步。
- 形状
输入:
输出: (与输入形状相同)
注意
Batchnorm 统计量的同步仅在训练期间发生,即当设置为
model.eval()
或self.training
为False
时,同步会被禁用。示例
>>> # With Learnable Parameters >>> m = nn.SyncBatchNorm(100) >>> # creating process group (optional) >>> # ranks is a list of int identifying rank ids. >>> ranks = list(range(8)) >>> r1, r2 = ranks[:4], ranks[4:] >>> # Note: every rank calls into new_group for every >>> # process group created, even if that rank is not >>> # part of the group. >>> process_groups = [torch.distributed.new_group(pids) for pids in [r1, r2]] >>> process_group = process_groups[0 if dist.get_rank() <= 3 else 1] >>> # Without Learnable Parameters >>> m = nn.BatchNorm3d(100, affine=False, process_group=process_group) >>> input = torch.randn(20, 100, 35, 45, 10) >>> output = m(input) >>> # network is nn.BatchNorm layer >>> sync_bn_network = nn.SyncBatchNorm.convert_sync_batchnorm(network, process_group) >>> # only single gpu per process is currently supported >>> ddp_sync_bn_network = torch.nn.parallel.DistributedDataParallel( >>> sync_bn_network, >>> device_ids=[args.local_rank], >>> output_device=args.local_rank)
- classmethod convert_sync_batchnorm(module, process_group=None)[source]#
将模型中所有
BatchNorm*D
层转换为torch.nn.SyncBatchNorm
层。- 参数
module (nn.Module) – 包含一个或多个
BatchNorm*D
层的模块。process_group (optional) – 用于限定同步范围的进程组,默认为整个 world。
- 返回
转换后带有
torch.nn.SyncBatchNorm
层的原始module
。如果原始module
本身就是一个BatchNorm*D
层,则会返回一个新的torch.nn.SyncBatchNorm
层对象。
示例
>>> # Network with nn.BatchNorm layer >>> module = torch.nn.Sequential( >>> torch.nn.Linear(20, 100), >>> torch.nn.BatchNorm1d(100), >>> ).cuda() >>> # creating process group (optional) >>> # ranks is a list of int identifying rank ids. >>> ranks = list(range(8)) >>> r1, r2 = ranks[:4], ranks[4:] >>> # Note: every rank calls into new_group for every >>> # process group created, even if that rank is not >>> # part of the group. >>> process_groups = [torch.distributed.new_group(pids) for pids in [r1, r2]] >>> process_group = process_groups[0 if dist.get_rank() <= 3 else 1] >>> sync_bn_module = torch.nn.SyncBatchNorm.convert_sync_batchnorm(module, process_group)