Signal/Android
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Android.git synced 2025-12-24 13:08:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use unbounded thread pool for Rx I/O scheduler.

Browse Source
This commit is contained in:
Cody Henthorne
2025-03-19 09:17:09 -04:00
committed by Alex Hart
parent 323697dfc9
commit 2dacb3b20f
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/src/main/java/org/thoughtcrime/securesms/ApplicationContext.java
View File

@@ -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;

3
core-util/src/main/java/org/signal/core/util/concurrent/SignalExecutors.java
View File

@@ -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()) {