目录：
1.说明
2.代码
说明：
/*
* IJob 一次只能执行一个任务，如果需要重复执行某个动作很多次，就可以用到并行任务 IJobParallelFor
*
* ParallelFor jobs使用 NativeArray作为数据源，并且运行在多个core上，每个job只负责处理完整数据的一个子集
* Execute(idx)方法对于数据源NativeArray中的每个item都调用一次
*
* 需要手动执行次数，表示需要分多少次独立Execute执行
* 一般直接取 NativeArray 的数组长度作为执行次数，一次处理一个数据
*
* 当一个native job提前完成它的batches，它会从其他的native job偷取一部分batches，然后继续执行
*
* 颗粒度问题：
* 分的太细会有work不断重建开销，分的太粗又会有单核负载问题
* 推荐：从1开始逐步增加，知道性能不再提高
*
*/
/*
*
* 注意事项：
* 1.不能在job中访问static数据
*
* 2.Flush scheduled batchs
* JobHandle.Complete：直接开始执行。
* 不flush batch会导致调度延迟到主线程等待batch执行结果时才触发执行
*
* 3.不要试图更新NativeContainer的内容
* navtiveArray[0]++
*
* 4.主线程在访问数据之前，需要依赖的job调用complete
* 不能只是check JobHandle.IsCompleted，而是需要手动调用JobHandle.Complete()
*
* 5.在主线程中使用Schedule和Complete
* 这两个函数只能在主线程中调用。不能因为一个job依赖另一个job，就在前一个job中手动schedule另一个job
*
* 6.在正确的时间使用Schedule和Complete
* Schedule：在数据填充完毕，立马调用
* Complete：只在你需要result的时候调用
*
* 7.NativeContainer添加read-only标记
* 默认是可读写的，如果确定只读就标记为read-only，可以提升性能
*
* 8.不要在job里面分配托管内存managed memory
* 在job里面分配托管内存是非常慢的，而且会导致Burst compiler没法使用
* Burst是基于LLVM的后端编译技术，它可以利用平台特定能力将c# jobs代码编译成高度优化过的机器码
*
*/
代码如下:
using System.Collections;
using System.Collections.Generic;
using Unity.Collections;
using Unity.Jobs;
using UnityEditor;
using UnityEngine;
public class TestJobParallelFor_1 : MonoBehaviour
{
public struct MyParallelJob : IJobParallelFor
{
public NativeArray<float> a;
public NativeArray<float> b;
public NativeArray<float> result;
public void Execute(int index)
{
result[index] = a[index] + b[index];
}
}
void ScheduleParallelJob()
{
NativeArray<float> a = new NativeArray<float>(10, Allocator.TempJob);
NativeArray<float> b = new NativeArray<float>(10, Allocator.TempJob);
NativeArray<float> result = new NativeArray<float>(10, Allocator.TempJob);
int dataCount = 10;
for (int i = 0; i < dataCount; i++)
{
a[i] = i * 0.3f;
b[i] = i * 0.5f;
}
MyParallelJob jobData = new MyParallelJob();
jobData.a = a;
jobData.b = b;
jobData.result = result;
JobHandle handle = jobData.Schedule(dataCount, 1);
handle.Complete();
for (int i = 0; i < dataCount; i++)
{
Debug.LogError(result[i]);
}
a.Dispose();
b.Dispose();
result.Dispose();
}
private void Update()
{
ScheduleParallelJob();
}
}
