
在数据处理和机器学习领域,我们经常需要计算两组向量(例如,特征向量集A和B)之间的所有或部分两两距离。当所需距离的比例非常小(例如小于1%)时,如果采用传统的全矩阵计算方法,会产生大量的冗余计算,导致性能瓶颈。
考虑以下场景:给定两个向量集合 A (形状 (N, D)) 和 B (形状 (M, D)),以及一个掩码矩阵 M (形状 (N, M)),其中 M[i, j] 为 True 表示我们需要计算 A[i] 和 B[j] 之间的距离,否则不需要。
传统的 NumPy 方法通常会先计算所有可能的 N * M 对向量的差分,然后计算它们的范数,最后通过掩码过滤掉不需要的值。
import numpy as np A = np.array([[1, 2], [2, 3], [3, 4]]) # (3, 2) B = np.array([[4, 5], [5, 6], [6, 7], [7, 8], [8, 9]]) # (5, 2) M = np.array([[0, 0, 0, 1, 0], [1, 1, 0, 0, 0], [0, 0, 0, 0, 1]]) # (3, 5) # 计算所有可能的差分矩阵 (3, 5, 2) diff = A[:, None] - B[None, :] # 计算所有可能的欧氏距离 (3, 5) distances = np.linalg.norm(diff, ord=2, axis=2) # 应用掩码,将不需要的距离置为0 masked_distances = distances * M
这种方法的问题在于,即使 M 矩阵非常稀疏,diff 和 distances 矩阵仍然是稠密的,这意味着我们计算了大量最终会被丢弃的距离。当 N 和 M 达到数千级别时,这种冗余计算会严重拖慢程序执行速度。
尝试使用 np.vectorize 创建条件函数也未能解决性能问题,因为它本质上只是将 Python 循环包装起来,并没有带来底层的性能优化。
为了解决上述性能瓶颈,我们引入一种结合 Numba 即时编译和 SciPy 稀疏矩阵(Compressed Sparse Row, CSR)的优化方案。该方案的核心思想是:
首先,我们定义一个 Numba 加速的欧氏距离计算函数。在循环中计算欧氏距离比调用 np.linalg.norm 更快,因为 np.linalg.norm 内部可能涉及额外的开销。
import numba as nb
import numpy as np
import scipy.sparse
import math
@nb.njit()
def euclidean_distance(vec_a, vec_b):
"""
使用 Numba 加速计算两个向量之间的欧氏距离。
"""
acc = 0.0
for i in range(vec_a.shape[0]):
acc += (vec_a[i] - vec_b[i]) ** 2
return math.sqrt(acc)接下来,我们实现一个 Numba 加速的内部函数 masked_distance_inner,它负责遍历掩码矩阵,只在 mask[i, j] 为 True 时计算距离,并将结果直接填充到 CSR 矩阵所需的 data、indices 和 indptr 数组中。
@nb.njit()
def masked_distance_inner(data, indices, indptr, matrix_a, matrix_b, mask):
"""
Numba 加速的核心函数,根据掩码计算距离并填充 CSR 矩阵的组成部分。
"""
write_pos = 0
N, M = matrix_a.shape[0], matrix_b.shape[0]
# 遍历所有可能的向量对
for i in range(N):
for j in range(M):
# 仅在掩码为 True 时计算距离
if mask[i, j]:
# 记录距离值
data[write_pos] = euclidean_distance(matrix_a[i], matrix_b[j])
# 记录该距离值对应的列索引
indices[write_pos] = j
write_pos += 1
# 记录当前行结束后,下一行在 data 和 indices 中的起始位置
indptr[i + 1] = write_pos
# 确保所有预分配的空间都被使用
assert write_pos == data.shape[0]
assert write_pos == indices.shape[0]masked_distance 函数作为外部接口,负责准备数据、计算稀疏矩阵的非零元素数量,并调用 Numba 优化的内部函数,最终构建并返回 scipy.sparse.csr_matrix 对象。
def masked_distance(matrix_a, matrix_b, mask):
"""
封装函数,用于设置并执行稀疏距离计算,返回 CSR 矩阵。
"""
N, M = matrix_a.shape[0], matrix_b.shape[0]
assert mask.shape == (N, M)
# 确保掩码是布尔类型
mask = mask != 0
# 统计稀疏矩阵中非零元素的总数
sparse_length = mask.sum()
# 预分配 CSR 矩阵的组成部分数组
# data 和 indices 不需要初始化为零,直接填充更快
data = np.empty(sparse_length, dtype='float64') # 存储距离值
indices = np.empty(sparse_length, dtype='int64') # 存储列索引
indptr = np.zeros(N + 1, dtype='int64') # 存储行指针,需初始化首位为0
# 调用 Numba 优化的核心函数进行计算和填充
masked_distance_inner(data, indices, indptr, matrix_a, matrix_b, mask)
# 构建并返回 SciPy CSR 稀疏矩阵
return scipy.sparse.csr_matrix((data, indices, indptr), shape=(N, M))为了验证优化方案的有效性,我们使用大规模随机数据进行测试。
# 示例数据生成 A_big = np.random.rand(2000, 10) # 2000个向量,每个10维 B_big = np.random.rand(4000, 10) # 4000个向量,每个10维 # 创建一个非常稀疏的掩码,只有0.1%的元素为True M_big = np.random.rand(A_big.shape[0], B_big.shape[0]) < 0.001 # 性能测试 (在 Jupyter/IPython 环境中运行) # %timeit masked_distance(A_big, B_big, M_big)
在测试中,对于 A_big 形状为 (2000, 10),B_big 形状为 (4000, 10),且 M_big 只有 0.1% 元素为 True 的场景,该优化方案比原始的 NumPy 全矩阵计算方法快约 40倍。当向量维度增加到 1000 时,性能提升甚至可以达到 1000倍。
测试结果示例:
这种显著的性能提升主要得益于以下几点:
当需要计算两组向量间非常稀疏的交叉差分距离时,结合 Numba 进行即时编译和 SciPy CSR 稀疏矩阵进行结果存储的策略,能够显著提升计算效率。通过避免不必要的计算和优化数据存储,该方法在大规模稀疏场景下展现出强大的性能优势,是处理此类问题的理想解决方案。
以上就是高效计算稀疏交叉差分:Numba与CSR矩阵的联合优化的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号