Firebase 存储 RejectedExecutionException 异常

Question

在我的项目中，我使用 Firebase 存储来下载一些图像文件 - 确切地说是 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 块中调用自身。有点像这里的 C# 示例表单：https://stackoverflow.com/a/49043177/679553

我修改了该链接中的一个示例，使其更接近您的情况。我在移动设备上，所以这是我目前能做的最好的事情：) 您可以将 ref 设为您班级中的一个字段，并在 continueWith 块内更新它。

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