Android Unity - 在后台线程上加载文件

Question

我需要在我的应用程序中加载一个文件，因为它很大（大约 250MB），我需要在主线程中执行这个加载。更何况Android上的assets不是存放在一个常规目录下，而是一个jar文件，我需要使用WWW或者UnityWebRequest类。

我最终得到了这样的辅助方法：

public static byte[] ReadAllBytes(string filePath)
{

    if (Application.platform == RuntimePlatform.Android)
    {
        var reader = new WWW(filePath);
        while (!reader.isDone) { }

        return reader.bytes;
    }
    else
    {
        return File.ReadAllBytes(filePath);
    }
}

问题是我不能在后台线程上使用它——Unity 不允许我在那里创建 WWW 对象。如何创建这样的方法，它将读取当前线程上的这些字节？

Answer 1

只需将您的 while 循环放在 CoRoutine 中，而您的请求未完成到 yield return。完成后调用您要使用数据的方法：

IEnumerator MyMethod()
{
    var reader = new WWW(filePath);
    while (!reader.isDone) 
    { 
        yield return; // <- use endofFrame or Wait For ore something else if u want
    }
    LoadingDoneDoData(reader.bytes);
}

void LoadingDoneDoData(bytes[] data)
{
    // your Code here
}

Answer 2

我认为你可以使用类似的东西

public static async void ReadAllBytes(string filePath, Action<byte[]> successCallback)
{
    byte[] result;
    using (FileStream stream = File.Open(filePath, FileMode.Open))
    {
        result = new byte[stream.Length];
        await stream.ReadAsync(result, 0, (int)stream.Length);
    }

    // Now pass the byte[] to the callback
    successCallback.Invoke();
}

(Source)

我猜你可以像这样使用它

TheClass.ReadAllBytes(
    "a/file/path/",

    // What shall be done as soon as you have the byte[]
    (bytes) =>
    {
        // What you want to use the bytes for
    }
);

我不是多线程专家，但here 和here 你可以找到更多示例以及async - await 和Unity3d 的操作方法。

---

另外，新的Unity Jobsystem 也可能对您感兴趣。

Answer 3

我最终得到了以下解决方案。我没有找到加载原始文件主线程的方法，但我设法在协程中加载它并在后台线程上对该文件执行进一步（也是繁重的）操作。我做了一个这样的静态方法：

public static void ReadAllBytesInCoroutine(MonoBehaviour context, string filePath, Action<ReadBytesInCoroutineResult> onComplete)
{
    context.StartCoroutine(ReadFileBytesAndTakeAction(filePath, onComplete));
}

private static IEnumerator ReadFileBytesAndTakeAction(string filePath, Action<ReadBytesInCoroutineResult> followingAction)
{
    WWW reader = null;

    try
    {
        reader = new WWW(filePath);
    }
    catch(Exception exception)
    {
        followingAction.Invoke(ReadBytesInCoroutineResult.Failure(exception));
    }

    while (reader != null && !reader.isDone)
    {
        yield return null;
    }
    followingAction.Invoke(ReadBytesInCoroutineResult.Success(reader.bytes));
}

ReadBytesInCoroutineResult 是我简单的自定义数据类：

public class ReadBytesInCoroutineResult
{
    public readonly bool successful;
    public readonly byte[] data;
    public readonly Exception reason;

    private ReadBytesInCoroutineResult(bool successful, byte[] data, Exception reason)
    {
        this.successful = successful;
        this.data = data;
        this.reason = reason;
    }

    public static ReadBytesInCoroutineResult Success(byte[] data)
    {
        return new ReadBytesInCoroutineResult(true, data, null);
    }

    public static ReadBytesInCoroutineResult Failure(Exception reason)
    {
        return new ReadBytesInCoroutineResult(true, null, reason);
    }

}

这样我就有了一种机制可以在任何地方（只要它在主线程上）在协程中加载文件。同步加载文件，但由于协程，它没有阻塞主线程。后来我调用这个函数并在一个单独的线程上获取获取的字节，在那里我对它们执行繁重的计算。

    ResourcesUtils.ReadAllBytesInCoroutine(monoBehavior, filePath, (bytes) => {

        //here I run an async method which takes bytes as parameter

    });