Request for IJobChunk.ScheduleSingle

Similar to IJobProcessComponentData.ScheduleSingle, can we also get a schedule function which runs single-threaded for IJobChunk?

 

IJobChunk is run single threaded. If you pass down the job handle, you can tell other IJobChunk to wait for the previous one.

Code (CSharp):

1. for(i = 0; i > length; i++){
2.      var job = new IJobChunk(); // Create Job
3.      inputdeps = job.schedule(this, inputdeps); // Tell this job to wait for previous job in previous loop
4. }

I'm not tested yet but I think relatively job handle should work like that.

 

IJobChunk runs as a parallel-for job. If you look into the source (IJobChunk.cs) you'll see this line

Code (csharp):

1. return JobsUtility.ScheduleParallelFor(ref scheduleParams, totalChunks, 1);

A ScheduleSingle extension method would call JobsUtility.Schedule instead of ScheduleParallelFor.

 

Yeah that's not true. Chunks are spread across threads.

 

Well my bad. That is badly written and I do not have that deep understand of ECS.

 

Sorry didn't mean to come off so blunt.

From memory, every job except IJob is parallel by default.

 

bump

 

Since it might be a while for us to get this, I wrote a quick'n'dirty work-around

Code (csharp):

1. public static JobHandle ScheduleSingle<T>(this T job, EntityQuery query, JobHandle dependsOn)
2.     where T : struct, IJobChunk {
3.   var chunks = query.CreateArchetypeChunkArray(Allocator.TempJob, out JobHandle chunksHandle);
4.   dependsOn = JobHandle.CombineDependencies(dependsOn, chunksHandle);
5.   return new JobChunkSingleRunner<T> {
6.     RealJob = job,
7.     Chunks = chunks,
8.   }.Schedule(dependsOn);
9. }
10.  
11. [BurstCompile]
12. struct JobChunkSingleRunner<T> : IJob where T : IJobChunk {
13.   public T RealJob;
14.   [DeallocateOnJobCompletion]
15.   public NativeArray<ArchetypeChunk> Chunks;
16.  
17.   public void Execute() {
18.     int firstEntityIndex = 0;
19.     for (int i = 0; i < Chunks.Length; ++i) {
20.       RealJob.Execute(Chunks[i], i, firstEntityIndex);
21.       firstEntityIndex += Chunks[i].Count;
22.     }
23.   }
24. }

 

please add this.