r4sas/lightning-i2p
1
0
Fork 0
Code Issues Pull Requests Releases 1 Wiki Activity

Use executorservice instead of plain executor to facilitate shutdown

Browse Source
This commit is contained in:
Anthony Restaino 2015-09-27 11:58:58 -04:00
parent 7cec3bd6e4
commit e157d45d39
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/main/java/acr/browser/lightning/async/AsyncExecutor.java
View File

@ -6,6 +6,7 @@ import android.util.Log;
import java.util.ArrayDeque; import java.util.ArrayDeque;
import java.util.Queue; import java.util.Queue;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.RejectedExecutionException;
@ -17,7 +18,7 @@ public class AsyncExecutor implements Executor {
private static final String TAG = AsyncExecutor.class.getSimpleName(); private static final String TAG = AsyncExecutor.class.getSimpleName();
private static AsyncExecutor INSTANCE = new AsyncExecutor(); private static AsyncExecutor INSTANCE = new AsyncExecutor();
private Queue<Runnable> mQueue = new ArrayDeque<>(1); private Queue<Runnable> mQueue = new ArrayDeque<>(1);
private Executor mExecutor = Executors.newFixedThreadPool(4); private ExecutorService mExecutor = Executors.newFixedThreadPool(4);
private AsyncExecutor() {} private AsyncExecutor() {}
@ -35,6 +36,7 @@ public class AsyncExecutor implements Executor {
@Override @Override
protected void finalize() throws Throwable { protected void finalize() throws Throwable {
mExecutor.shutdownNow();
super.finalize(); super.finalize();
} }