java - Firebase Storage RejectedExecutionException 异常

Question

在我的项目中，我使用 Firebase Storage 下载一些图像文件——确切地说是 154 张图像。由于某些未知原因，我只设法下载了大约 130 个文件，然后我得到一个异常说明:

java.util.concurrent.RejectedExecutionException: Task com.google.firebase.storage.zzs@15c1d59d rejected from java.util.concurrent.ThreadPoolExecutor@270bfa12[Running, pool size = 3, active threads = 3, queued tasks = 128, completed tasks = 5]
    at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2011)
    at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:793)
    at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1339)
    at com.google.firebase.storage.zzu.zzv(Unknown Source)
    at com.google.firebase.storage.FileDownloadTask.schedule(Unknown Source)
    at com.google.firebase.storage.StorageTask.zzcny(Unknown Source)
    at com.google.firebase.storage.StorageReference.getFile(Unknown Source)
    at com.google.firebase.storage.StorageReference.getFile(Unknown Source)

我正在使用 for 循环调用 StorageReference.getFile() 并将文件下载到特定位置，如下所示:

        for (int i = 0; i < filesToDownload.size(); i++) {
            String image = filesToDownload.get(i);

            final File localFile = new 
               File(DeviceStorage.getExternalStorageDir(dirPath)
               + File.separator + fileName);
            StorageReference downloadPhotoRef = 
               getReference().child(folderName + File.separator + fileName);

            downloadPhotoRef.getFile(localFile);
            downloadFile(context, image);
        }

我很纳闷为什么会这样。我找不到任何解决方案和其他人遇到同样的问题。我在服务中运行此代码。如果我下载的文件少于 130 个，我不会收到错误的唯一方法，但这对我不利。

请帮忙。

Answer 1

您正在启动太多并行下载任务。线程系统因此放弃。更多相关信息:https://stackoverflow.com/a/8183463/679553

你应该尝试序列化这个过程的部分内容，也许 10 10 下载它们？ .continueWith() 这是一个好的开始:https://firebase.googleblog.com/2016/09/become-a-firebase-taskmaster-part-3_29.html

此刻，您的 getFile() 调用产生了一个新的下载任务并无阻塞地返回。您可以在上一次下载完成后使用 .continueWith() 开始下一次下载，而不是使用 for 循环的下一次迭代开始下一次下载。

实现它的一种方法是创建一个返回任务并在最后一个 continueWith block 中回调自身的函数。有点像这里的 C# 示例表单:https://stackoverflow.com/a/49043177/679553

我修改了该链接中的一个示例，使其更接近您的情况。我在移动设备上，所以这是我目前能做的最好的事情:) 你可以让 ref 成为你类(class)中的一个字段，并在 continueWith block 中更新它.

Task DoStuff()
{
    return ref.getFile(() => DoWork1())
        .ContinueWith((t1) => DoWork2())
        .ContinueWith(t2 => DoWork3())
        .ContinueWith(t3=> DoStuff());
}