通常,一个作业依赖于另一个作业的结果。例如,作业 A 可能会写入作业 B 用作输入的 NativeArray
。在调度依赖作业时,您必须告知作业系统此类依赖关系。作业系统在依赖的作业完成之前不会运行依赖的作业。一个作业可以依赖多个作业。
您还可以有一系列作业,其中每个作业都依赖于前一个作业。但是,依赖关系会延迟作业执行,因为您必须等待作业的所有依赖关系完成才能运行。完成依赖作业必须首先完成它依赖的任何作业,以及这些作业依赖的任何作业。
当您调用作业的 Schedule
方法时,它会返回一个 JobHandle
。您可以将 JobHandle
用作其他作业的依赖项。如果一个作业依赖于另一个作业的结果,您可以将第一个作业的 JobHandle
作为参数传递给第二个作业的 Schedule
方法,如下所示
JobHandle firstJobHandle = firstJob.Schedule();
secondJob.Schedule(firstJobHandle);
如果一个作业有很多依赖项,您可以使用 JobHandle.CombineDependencies
方法将它们合并。CombineDependencies
允许您将依赖项传递到 Schedule
方法。
NativeArray<JobHandle> handles = new NativeArray<JobHandle>(numJobs, Allocator.TempJob);
// Populate `handles` with `JobHandles` from multiple scheduled jobs...
JobHandle jh = JobHandle.CombineDependencies(handles);
以下是一个具有多个依赖项的多个作业的示例。最佳实践是将作业代码 (MyJob
和 AddOneJob
) 放入与 Update
和 LateUpdate
代码分开的文件中,但为了清晰起见,此示例在一个文件中
using UnityEngine;
using Unity.Collections;
using Unity.Jobs;
public class MyDependentJob : MonoBehaviour
{
// Create a native array of a single float to store the result. This example waits for the job to complete.
NativeArray<float> result;
// Create a JobHandle to access the results
JobHandle secondHandle;
// Set up the first job
public struct MyJob : IJob
{
public float a;
public float b;
public NativeArray<float> result;
public void Execute()
{
result[0] = a + b;
}
}
// Set up the second job, which adds one to a value
public struct AddOneJob : IJob
{
public NativeArray<float> result;
public void Execute()
{
result[0] = result[0] + 1;
}
}
// Update is called once per frame
void Update()
{
// Set up the job data for the first job
result = new NativeArray<float>(1, Allocator.TempJob);
MyJob jobData = new MyJob
{
a = 10,
b = 10,
result = result
};
// Schedule the first job
JobHandle firstHandle = jobData.Schedule();
// Setup the data for the second job
AddOneJob incJobData = new AddOneJob
{
result = result
};
// Schedule the second job
secondHandle = incJobData.Schedule(firstHandle);
}
private void LateUpdate()
{
// Sometime later in the frame, wait for the job to complete before accessing the results.
secondHandle.Complete();
// All copies of the NativeArray point to the same memory, you can access the result in "your" copy of the NativeArray
// float aPlusBPlusOne = result[0];
// Free the memory allocated by the result array
result.Dispose();
}
}