diff --git a/app/src/main/java/org/thoughtcrime/securesms/ApplicationContext.java b/app/src/main/java/org/thoughtcrime/securesms/ApplicationContext.java
index ed6f703002..e37bde1370 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/ApplicationContext.java
+++ b/app/src/main/java/org/thoughtcrime/securesms/ApplicationContext.java
@@ -354,7 +354,7 @@ public class ApplicationContext extends Application implements AppForegroundObse
 
   private void initializeRx() {
     RxDogTag.install();
-    RxJavaPlugins.setInitIoSchedulerHandler(schedulerSupplier -> Schedulers.from(SignalExecutors.BOUNDED_IO, true, false));
+    RxJavaPlugins.setInitIoSchedulerHandler(schedulerSupplier -> Schedulers.from(SignalExecutors.UNBOUNDED, true, false));
     RxJavaPlugins.setInitComputationSchedulerHandler(schedulerSupplier -> Schedulers.from(SignalExecutors.BOUNDED, true, false));
     RxJavaPlugins.setErrorHandler(e -> {
       boolean wasWrapped = false;
diff --git a/core-util/src/main/java/org/signal/core/util/concurrent/SignalExecutors.java b/core-util/src/main/java/org/signal/core/util/concurrent/SignalExecutors.java
index 38437a0f38..81d8b1dc22 100644
--- a/core-util/src/main/java/org/signal/core/util/concurrent/SignalExecutors.java
+++ b/core-util/src/main/java/org/signal/core/util/concurrent/SignalExecutors.java
@@ -10,7 +10,6 @@ import org.signal.core.util.ThreadUtil;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.SynchronousQueue;
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -52,7 +51,7 @@ public final class SignalExecutors {
                                                            maxThreads,
                                                            timeoutSeconds,
                                                            TimeUnit.SECONDS,
-                                                           new SynchronousQueue<>() {
+                                                           new LinkedBlockingQueue<>() {
                                                              @Override
                                                              public boolean offer(Runnable runnable) {
                                                                if (isEmpty()) {