run roster sync in replacing task manager

1 files changed, 10 insertions, 17 deletions

diff --git a/src/main/java/de/pixart/messenger/utils/SerialSingleThreadExecutor.java b/src/main/java/de/pixart/messenger/utils/SerialSingleThreadExecutor.java
index ea1fb81f1..1562160fd 100644
--- a/src/main/java/de/pixart/messenger/utils/SerialSingleThreadExecutor.java
+++ b/src/main/java/de/pixart/messenger/utils/SerialSingleThreadExecutor.java
@@ -11,8 +11,8 @@ import de.pixart.messenger.Config;
 
 public class SerialSingleThreadExecutor implements Executor {
 
-    final Executor executor = Executors.newSingleThreadExecutor();
-    protected final ArrayDeque<Runnable> tasks = new ArrayDeque<>();
+    private final Executor executor = Executors.newSingleThreadExecutor();
+	final ArrayDeque<Runnable> tasks = new ArrayDeque<>();
     private Runnable active;
     private final String name;
 
@@ -20,26 +20,19 @@ public class SerialSingleThreadExecutor implements Executor {
         this(name, false);
     }
 
-    public SerialSingleThreadExecutor(String name, boolean prepareLooper) {
+    SerialSingleThreadExecutor(String name, boolean prepareLooper) {
         if (prepareLooper) {
-            execute(new Runnable() {
-                @Override
-                public void run() {
-                    Looper.prepare();
-                }
-            });
+            execute(Looper::prepare);
         }
         this.name = name;
     }
 
     public synchronized void execute(final Runnable r) {
-        tasks.offer(new Runnable() {
-            public void run() {
-                try {
-                    r.run();
-                } finally {
-                    scheduleNext();
-                }
+        tasks.offer(() -> {
+            try {
+                r.run();
+            } finally {
+                scheduleNext();
             }
         });
         if (active == null) {
@@ -47,7 +40,7 @@ public class SerialSingleThreadExecutor implements Executor {
         }
     }
 
-    protected synchronized void scheduleNext() {
+    private synchronized void scheduleNext() {
         if ((active = tasks.poll()) != null) {
             executor.execute(active);
             int remaining = tasks.size();