本文首發於“洪流學堂”微信公眾號。
洪流學堂，讓你學Unity快人幾步

上一篇文章我們講了job system，這篇文章來看看如何使用job system以及常見的問題。

Scheduling jobs工作排程

如前一節所述，作業系統依賴blittable資料和NativeContainers。要排程job，需要實現IJob介面，建立結構體的例項，填充資料並呼叫Schedule。當你安排這個job後，會返回一個可用作其他job的依賴項的job控制代碼，或者當你需要再次訪問傳遞給主執行緒上的作業的NativeContainer時，你可以等待它。

當你安排job時，job實際上不會立即開始執行。我們建立了一批作業來安排需要重新整理的作業。在ECS中是隱式重新整理的，在ECS外部，需要通過呼叫靜態函式JobHandle.ScheduleBatchedJobs（）

// Job將兩個浮點值相加
public struct MyJob : IJob
{
    public float a;
    public float b;
    NativeArray<float> result;
    public void Execute()
    {
        result[0] = a + b;
    }
}

//建立一個單一float的本地陣列來儲存結果。這個例子將等待作業完成，這意味著我們可以使用Allocator.Temp
NativeArray<float> result = new NativeArray<float
 
>(1, Allocator.Temp);
//設定工作資料
MyJob jobData = new MyJob();
jobData.a = 10;
jobData.b = 10;
jobData.result = result;
//安排作業
JobHandle handle = jobData.Schedule();
//等待作業完成
handle.Complete();
//NativeArray的所有副本指向同一個記憶體，我們可以訪問NativeArray中的結果
float aPlusB = result[0];
//釋放結果陣列分配的記憶體
result.Dispose（）;

如果我們有多個作業在相同的資料上執行，我們需要使用依賴關係：

public struct AddOneJob : IJob
{
    public NativeArray<float> result;
    public void Execute()
    {
        result[0] = result[0] + 1;
    }
}

NativeArray<float> result = new NativeArray<float>(1, Allocator.Temp);
//設定工作資料
MyJob jobData = new MyJob();
jobData.a = 10;
jobData.b = 10;
jobData.result = result;
//安排作業
JobHandle firstHandle = jobData.Schedule();
AddOneJob incJobData = new AddOneJob();
incJobData.result = result;
JobHandle handle = incJobData.Schedule(firstHandle);
//等待作業完成
handle.Complete();
//NativeArray的所有副本指向同一個記憶體，我們可以訪問NativeArray中的結果
float aPlusB = result[0];
//釋放結果陣列分配的記憶體
result.Dispose();

ParallelFor job

如上一節所述，排程job意味著只能有一項工作在做一件事。在一個遊戲中，想要在大量物體上執行相同操作的情況非常普遍。對於這種情況，有一個單獨的工作型別：IJobParallelFor。IJobParallelFor的行為與IJob類似，但不是單次執行得到一個結果而是一次得到批量結果。系統實際上不會為每個專案安排一個job，它會為每個CPU核心最多安排一個job，並重新分配工作負載，這些都在系統內部處理的。在排程ParallelForJobs時，必須指定要分割的陣列的長度，因為如果結構中有多個數組，則系統無法知道要將哪個陣列用作主資料。你還需要指定批次的數量。批處理計數控制你將獲得多少job，以及執行緒之間的工作重新分配的細化程度如何。擁有較低的批處理數量（如1）會使你線上程之間進行更均勻的工作分配。但是，它會帶來一些開銷，因此在某些情況下，稍微增加批次數量會更好。

//job 將兩個浮點數相加
public struct MyParallelJob : IJobParallelFor
{
    [ReadOnly]
    public NativeArray<float> a;
    [Readonly]
    public NativeArray<float> b;
    public NativeArray<float> result;
    public void Execute(int i)
    {
        result[i] = a[i] + b[i];
    }
}

var jobData = new MyParallelJob();
jobData.a = 10;  
jobData.b = 10;
jobData.result = result;
//使用結果陣列中的每個索引執行一次Execute並且每次處理過程只處理一個專案
JobHandle handle = jobData.Schedule(result.Length, 1);
//等待作業完成
handle.Complete();

常見的錯誤

這是使用job system時常見錯誤的集合：

• 從job中訪問靜態資料：這樣做意味著你在規避所有安全系統。如果你訪問了錯誤的東西，你會以非預期的方式導致Unity崩潰。（未來版本將使用靜態分析來禁止job訪問全域性變數）
• 不重新整理schedule batches（排程批次）：當你想啟動job時，需要使用JobHandle.ScheduleBatchedJobs() 重新整理schedule batches 。不這樣做會排程會無限期延遲，直到有人等待它的結果。
• 期望引用返回：由於不能使用引用返回，不能直接修改NativeArray的內容。nativeArray[0]++;同var temp = nativeArray[0]; temp++;一樣不會更新NativeAr強調內容ray中的值。（我們正在致力支援C＃7，它將增加ref return並解決此問題。）
• 不呼叫JobHandle.Complete：主執行緒可以使用資料之前要求所有的依賴項都執行完成。這意味著只檢查JobHandle.IsDone是不夠的，需要呼叫Complete來讓主執行緒取回NativeContainers的所有權。呼叫Complete還清理job debugger中的狀態。不這樣做會導致記憶體洩漏，這也適用於依賴前一幀的job來安排下一幀的job。

Unity：世界領先的遊戲，VR/AR引擎
《鄭洪智的Unity2018課》，傾盡我8年的開發經驗，結合最新的Unity2018，帶你從入門到精通。
目前預售拼團，5.5折！