in src/main/java/com/twitter/sbf/core/MHAlgorithm.java [247:261]
private IntSet lockAndReturnLockedColumns(SparseBinaryMatrix matrix, int vertexId) {
IntSet colsToLock = new IntOpenHashSet();
synchronized (this) {
for (int nId : g.getNeighbors(vertexId)) {
// SUPPRESS CHECKSTYLE NestedForDepth
for (int colId : matrix.getRow(nId)) {
if (!colsToLock.contains(colId)) {
colsToLock.add(colId);
colLocks[colId].lock();
}
}
}
}
return colsToLock;
}