aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java
diff options
context:
space:
mode:
authorChristian Schneppe <christian@pix-art.de>2016-05-31 21:38:06 +0200
committerChristian Schneppe <christian@pix-art.de>2016-05-31 21:38:06 +0200
commitc23642b8cd2c06c5f3e9cf7f88d31ed5c6f78614 (patch)
treea7c53e5dd6dd6e85213cff834d35316a29617753 /src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java
parent2cdc31a6887f242dfe4faca91af63ffd4e74ef67 (diff)
parentea6a008b39b0f669f66f3c8aec08b4deb3ece154 (diff)
Merge remote-tracking branch 'refs/remotes/siacs/master'
Diffstat (limited to 'src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java')
-rw-r--r--src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java19
1 files changed, 18 insertions, 1 deletions
diff --git a/src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java b/src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java
index bfb4668db..55489ee30 100644
--- a/src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java
+++ b/src/main/java/eu/siacs/conversations/utils/SerialSingleThreadExecutor.java
@@ -1,5 +1,7 @@
package eu.siacs.conversations.utils;
+import android.os.Looper;
+
import java.util.ArrayDeque;
import java.util.Queue;
import java.util.concurrent.Executor;
@@ -8,9 +10,24 @@ import java.util.concurrent.Executors;
public class SerialSingleThreadExecutor implements Executor {
final Executor executor = Executors.newSingleThreadExecutor();
- final Queue<Runnable> tasks = new ArrayDeque();
+ protected final Queue<Runnable> tasks = new ArrayDeque();
Runnable active;
+ public SerialSingleThreadExecutor() {
+ this(false);
+ }
+
+ public SerialSingleThreadExecutor(boolean prepareLooper) {
+ if (prepareLooper) {
+ execute(new Runnable() {
+ @Override
+ public void run() {
+ Looper.prepare();
+ }
+ });
+ }
+ }
+
public synchronized void execute(final Runnable r) {
tasks.offer(new Runnable() {
public void run() {