Misaki/Misaki.HighPerformance
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added ReleaseTempAllocator to JobScheduler

Browse Source
This commit is contained in:
Misaki
2025-12-09 12:31:51 +09:00
parent 0438fce10e
commit a0a4b347dd
3 changed files with 19 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
Misaki.HighPerformance.Jobs/JobScheduler.cs
View File

@@ -6,12 +6,9 @@ using System.Runtime.CompilerServices;
namespace Misaki.HighPerformance.Jobs; namespace Misaki.HighPerformance.Jobs;
/// <summary> public unsafe partial class JobScheduler
/// Provides a mechanism for scheduling and executing jobs across multiple worker threads.
/// </summary>
public sealed unsafe class JobScheduler : IDisposable
{ {
private static readonly TempJobAllocator* pTempAllocator; public static readonly TempJobAllocator* pTempAllocator;
public static AllocationHandle TempAllocatorHandle => pTempAllocator->Handle; public static AllocationHandle TempAllocatorHandle => pTempAllocator->Handle;
static JobScheduler() static JobScheduler()
@@ -20,6 +17,21 @@ public sealed unsafe class JobScheduler : IDisposable
pTempAllocator->Init(); pTempAllocator->Init();
} }
public static void ReleaseTempAllocator()
{
if (pTempAllocator != null)
{
pTempAllocator->Dispose();
MemoryUtility.Free(pTempAllocator);
}
}
}
/// <summary>
/// Provides a mechanism for scheduling and executing jobs across multiple worker threads.
/// </summary>
public sealed unsafe partial class JobScheduler : IDisposable
{
private const int _SLEEP_THRESHOLD = 100; private const int _SLEEP_THRESHOLD = 100;
private FreeList _jobDataAllocator; private FreeList _jobDataAllocator;

2
Misaki.HighPerformance.Jobs/Misaki.HighPerformance.Jobs.csproj
View File

@@ -6,7 +6,7 @@
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable> <Nullable>enable</Nullable>
<AllowUnsafeBlocks>True</AllowUnsafeBlocks> <AllowUnsafeBlocks>True</AllowUnsafeBlocks>
<AssemblyVersion>1.2.0</AssemblyVersion> <AssemblyVersion>1.2.1</AssemblyVersion>
<Version>$(AssemblyVersion)</Version> <Version>$(AssemblyVersion)</Version>
<Authors>Misaki</Authors> <Authors>Misaki</Authors>
<GeneratePackageOnBuild>True</GeneratePackageOnBuild> <GeneratePackageOnBuild>True</GeneratePackageOnBuild>

2
Misaki.HighPerformance.Jobs/TempJobAllocator.cs
View File

@@ -78,7 +78,7 @@ public unsafe struct TempJobAllocator : IAllocator, IDisposable
Interlocked.Decrement(ref selfPtr->_allocationsPerFrame[selfPtr->_currentFrameIndex]); Interlocked.Decrement(ref selfPtr->_allocationsPerFrame[selfPtr->_currentFrameIndex]);
} }
public int IncrementFrame() public int AdvanceFrame()
{ {
var allocations = Interlocked.Exchange(ref _allocationsPerFrame[_currentFrameIndex], 0); var allocations = Interlocked.Exchange(ref _allocationsPerFrame[_currentFrameIndex], 0);