内部类完成后，Java开始下一个循环迭代

Question

所以我陷入了一个非常基本的 Java 问题。

也就是说，我有一个迭代，需要在内部类完成后进入下一个循环。但由于内部类需要花费大量时间，并且内部类中可以访问的变量必须是final > 它抛出了我RejectedExecutionException。

java.util.concurrent.RejectedExecutionException: Task android.os.AsyncTask$3@290074 rejected from java.util.concurrent.ThreadPoolExecutor@d50b99d[Running, pool size = 17, active threads = 17, queued tasks = 128, completed tasks = 42]

这是引发异常的简化解决方案。

for (int i = 0; i < 10;i++) {

        String[] cmd = { "-i",  imageToBeFiltered.toString(), "-filter_complex", filters[loopCounter], imageWithFilter.toString()};

        ffmpeg.execute(cmd, new ExecuteBinaryResponseHandler() {

            @Override
            public void onSuccess(String message) {
                super.onSuccess(message);

                //Continue loop only if it has reached onSuccess or onFailure

            }
            @Override
            public void onFailure(String message) {
                super.onFailure(message);
                //Continue loop only if it has reached onSuccess or onFailure
            }
        });
    }
}

在执行正常的fori循环时，它并不总是等待所有终端调用完成然后继续。

Answer 1

你考虑过递归吗？

void myMethod(int index) {
    String[] cmd = { "-i",  imageToBeFiltered.toString(), "-filter_complex", filters[loopCounter], imageWithFilter.toString()};

    ffmpeg.execute(cmd, new ExecuteBinaryResponseHandler() {

        @Override
        public void onSuccess(String message) {
            super.onSuccess(message);

            if (index < 10) myMethod(index++);

        }
        @Override
        public void onFailure(String message) {
            super.onFailure(message);

            if (index < 10) myMethod(index++);
        }
    });
}

编辑:

我猜测 loopCounter 应该是索引，在这种情况下，如果您使用此代码，您将需要更改它。