mlemanczyk/Recyclable.Collections
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Local function replaced with Lambda for readability in RecyclableList.DoIndexOfParallel.

Browse Source
This commit is contained in:
mlemanczyk committed 2023-05-01 12:39:23 +02:00
1 parent 948156b897
commit b038bcfdc9
1 file changed
+9 -36
Download Patch File Download Diff File Expand all files Collapse all files
Recyclable.Collections/RecyclableList.cs
+9 -36
View File
@@ -287,42 +287,7 @@ namespace Recyclable.Collections
Exception? ex = null;
// (long)(_longCount * 0.329) => most efficient step, based on benchmarks
ItemRangesIterator.Iterate(0, _blockSize, _blockSizePow2BitShift, _longCount, _longCountIndexOfStep, LocalIndexOf);
allDoneSignal.SignalAndWait();
if (ex == null)
{
return foundItemIndex;
}
ex.CaptureAndRethrow();
return ItemNotFoundIndexLong;
//int blockIndex = 0;
//int itemIndex = 0;
//long itemsCount = _longCount;
//while (itemsCount > step)
//{
// if (!LocalIndexOf(new(blockIndex, itemIndex, step)))
// {
// break;
// }
// itemsCount -= step;
// //blockIndex = (int)Math.DivRem(itemIndex + step, blockSize, out itemIndex);
// blockIndex += (int)((itemIndex + step) >> _blockSizePow2BitShift);
// itemIndex = (int)((itemIndex + step) & _blockSizeMinus1);
// //itemIndex += step;
// //while (itemIndex >= blockSize)
// //{
// // blockIndex++;
// // itemIndex -= blockSize;
// //}
//}
//_ = LocalIndexOf(new(blockIndex, itemIndex, itemsCount));
[MethodImpl(MethodImplOptions.AggressiveInlining | MethodImplOptions.AggressiveOptimization)]
bool LocalIndexOf(ItemRange itemRange)
ItemRangesIterator.Iterate(0, _blockSize, _blockSizePow2BitShift, _longCount, _longCountIndexOfStep, itemRange =>
{
_ = allDoneSignal.AddParticipant();
_ = Task.Factory.StartNew(() =>
@@ -362,7 +327,15 @@ namespace Recyclable.Collections
//});
return !itemFoundSignal.IsSet;
});
allDoneSignal.SignalAndWait();
if (ex == null)
{
return foundItemIndex;
}
ex.CaptureAndRethrow();
return ItemNotFoundIndexLong;
}
[MethodImpl(MethodImplOptions.AggressiveOptimization)]