Skip to content

Commit 875b022

Browse files
committed
Clean up
1 parent 3fb3e16 commit 875b022

File tree

2 files changed

+1
-20
lines changed

2 files changed

+1
-20
lines changed

JobScheduler/Utils/IParallelJobProducer.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ public struct ParallelJobProducer<T> : IJob where T : struct, IParallelJobProduc
5757
/// <param name="singleThreaded">Whether the job producer should not spawn children</param>
5858
public ParallelJobProducer(int from, int to, T producer, int loopSize = 16, bool onlySingle = false, JobHandle source = default, bool singleThreaded = false)
5959
{
60+
6061
_sourceHandle = source;
6162
_from = from;
6263
_to = to;

JobScheduler/Worker.cs

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -51,26 +51,6 @@ public static bool Enqueue(JobHandle handle)
5151
return result;
5252
}
5353

54-
public static void ThreadRun(Object _)
55-
{
56-
while (_incomingQueue.TryDequeue(out var handle))
57-
{
58-
handle.Job?.Execute();
59-
ParallelForJobCommon.GlobalScheduler.Finish(handle);
60-
}
61-
}
62-
63-
public static void ForceEnqueue(JobHandle handle)
64-
{
65-
// handle.Job?.Execute();
66-
// ParallelForJobCommon.GlobalScheduler.Finish(handle);
67-
68-
_incomingQueue.ForceEnqueue(handle);
69-
_workAvailable.Set();
70-
71-
// ThreadPool.UnsafeQueueUserWorkItem(ThreadRun, null);
72-
}
73-
7454
/// <summary>
7555
/// Its <see cref="WorkStealingDeque{T}"/> with <see cref="JobHandle"/>s to process.
7656
/// </summary>

0 commit comments

Comments
 (0)