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

Tiny cleanup

Browse Source
This commit is contained in:
mlemanczyk committed 2023-05-21 15:09:01 +02:00
1 parent 95e1932769
commit 209dac1808
1 file changed
+85 -85
Download Patch File Download Diff File Expand all files Collapse all files
Recyclable.Collections.Benchmarks/POC/RecyclableListPoc.Benchmarks.IndexOf.cs
+85 -85
View File
@@ -42,7 +42,7 @@ namespace Recyclable.Collections.Benchmarks.POC
} }
} }
internal static class ItemRangePoolV1 internal static class ItemRangePoolV1
{ {
[ThreadStatic] [ThreadStatic]
private static readonly ObjectPool<ItemRangeV1> _shared; private static readonly ObjectPool<ItemRangeV1> _shared;
@@ -565,19 +565,19 @@ namespace Recyclable.Collections.Benchmarks.POC
else else
{ {
blockIndex = sourceBlockCount; blockIndex = sourceBlockCount;
while (true) while (true)
{ {
newMemoryBlocks[blockIndex] = new T[minBlockSize]; newMemoryBlocks[blockIndex] = new T[minBlockSize];
if (blockIndex + 1 < requiredBlockCount) if (blockIndex + 1 < requiredBlockCount)
{ {
blockIndex++; blockIndex++;
} }
else else
{ {
break; break;
} }
} }
} }
} }
list._reservedBlockCount = requiredBlockCount; list._reservedBlockCount = requiredBlockCount;
@@ -1239,7 +1239,7 @@ namespace Recyclable.Collections.Benchmarks.POC
GC.SuppressFinalize(this); GC.SuppressFinalize(this);
} }
} }
} }
#endregion #endregion
@@ -1694,35 +1694,35 @@ namespace Recyclable.Collections.Benchmarks.POC
} }
blockIndex = sourceBlockCount; blockIndex = sourceBlockCount;
while (true) while (true)
{ {
newMemoryBlocks[blockIndex] = blockArrayPool.Rent(minBlockSize); newMemoryBlocks[blockIndex] = blockArrayPool.Rent(minBlockSize);
if (blockIndex + 1 < requiredBlockCount) if (blockIndex + 1 < requiredBlockCount)
{ {
blockIndex++; blockIndex++;
} }
else else
{ {
break; break;
} }
} }
} }
else else
{ {
blockIndex = sourceBlockCount; blockIndex = sourceBlockCount;
while (true) while (true)
{ {
newMemoryBlocks[blockIndex] = new T[minBlockSize]; newMemoryBlocks[blockIndex] = new T[minBlockSize];
if (blockIndex + 1 < requiredBlockCount) if (blockIndex + 1 < requiredBlockCount)
{ {
blockIndex++; blockIndex++;
} }
else else
{ {
break; break;
} }
} }
} }
} }
list._reservedBlockCount = requiredBlockCount; list._reservedBlockCount = requiredBlockCount;
@@ -2811,35 +2811,35 @@ namespace Recyclable.Collections.Benchmarks.POC
} }
blockIndex = sourceBlockCount; blockIndex = sourceBlockCount;
while (true) while (true)
{ {
newMemoryBlocks[blockIndex] = blockArrayPool.Rent(minBlockSize); newMemoryBlocks[blockIndex] = blockArrayPool.Rent(minBlockSize);
if (blockIndex + 1 < requiredBlockCount) if (blockIndex + 1 < requiredBlockCount)
{ {
blockIndex++; blockIndex++;
} }
else else
{ {
break; break;
} }
} }
} }
else else
{ {
blockIndex = sourceBlockCount; blockIndex = sourceBlockCount;
while (true) while (true)
{ {
newMemoryBlocks[blockIndex] = new T[minBlockSize]; newMemoryBlocks[blockIndex] = new T[minBlockSize];
if (blockIndex + 1 < requiredBlockCount) if (blockIndex + 1 < requiredBlockCount)
{ {
blockIndex++; blockIndex++;
} }
else else
{ {
break; break;
} }
} }
} }
} }
list._reservedBlockCount = requiredBlockCount; list._reservedBlockCount = requiredBlockCount;
@@ -3561,27 +3561,27 @@ namespace Recyclable.Collections.Benchmarks.POC
} }
} }
internal sealed class ParallelSynchronizationContextV4 : IDisposable internal sealed class ParallelSynchronizationContextV4 : IDisposable
{ {
public readonly ManualResetEventSlimmer ItemFoundSignal; public readonly ManualResetEventSlimmer ItemFoundSignal;
public readonly Barrier AllDoneSignal; public readonly Barrier AllDoneSignal;
public long FoundItemIndex; public long FoundItemIndex;
public Exception? Exception; public Exception? Exception;
public ParallelSynchronizationContextV4(int participantCount) public ParallelSynchronizationContextV4(int participantCount)
{ {
ItemFoundSignal = ManualResetEventSlimmerPool.Create(false); ItemFoundSignal = ManualResetEventSlimmerPool.Create(false);
AllDoneSignal = new(participantCount); AllDoneSignal = new(participantCount);
} }
public void Dispose() public void Dispose()
{ {
ItemFoundSignal.Dispose(); ItemFoundSignal.Dispose();
AllDoneSignal.Dispose(); AllDoneSignal.Dispose();
GC.SuppressFinalize(this); GC.SuppressFinalize(this);
} }
} }
internal class RecyclableListIndexOfV4<T> : IDisposable, IList<T> internal class RecyclableListIndexOfV4<T> : IDisposable, IList<T>
{ {