TheArchive/session-android
1
0
Fork 0
mirror of https://github.com/oxen-io/session-android.git synced 2025-06-09 15:58:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Name threads more consistently.

Browse Source
This commit is contained in:
Greyson Parrelli 2019-07-01 16:34:02 -04:00
parent 9c196bd2d5
commit ff3890cc12
6 changed files with 6 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/org/thoughtcrime/securesms/audio/AudioCodec.java
View File

@ -85,7 +85,7 @@ public class AudioCodec {
setFinished(); setFinished();
} }
} }
}, AudioCodec.class.getSimpleName()).start(); }, "signal-AudioCodec").start();
} }
private synchronized boolean isRunning() { private synchronized boolean isRunning() {

4
src/org/thoughtcrime/securesms/audio/AudioRecorder.java
View File

@ -11,10 +11,10 @@ import android.util.Pair;
import org.thoughtcrime.securesms.providers.BlobProvider; import org.thoughtcrime.securesms.providers.BlobProvider;
import org.thoughtcrime.securesms.util.MediaUtil; import org.thoughtcrime.securesms.util.MediaUtil;
import org.thoughtcrime.securesms.util.ThreadUtil;
import org.thoughtcrime.securesms.util.Util; import org.thoughtcrime.securesms.util.Util;
import org.thoughtcrime.securesms.util.concurrent.ListenableFuture; import org.thoughtcrime.securesms.util.concurrent.ListenableFuture;
import org.thoughtcrime.securesms.util.concurrent.SettableFuture; import org.thoughtcrime.securesms.util.concurrent.SettableFuture;
import org.thoughtcrime.securesms.util.concurrent.SignalExecutors;
import java.io.IOException; import java.io.IOException;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
@ -24,7 +24,7 @@ public class AudioRecorder {
private static final String TAG = AudioRecorder.class.getSimpleName(); private static final String TAG = AudioRecorder.class.getSimpleName();
private static final ExecutorService executor = ThreadUtil.newDynamicSingleThreadedExecutor(); private static final ExecutorService executor = SignalExecutors.newCachedSingleThreadExecutor("signal-AudioRecorder");
private final Context context; private final Context context;

2
src/org/thoughtcrime/securesms/jobmanager/JobManager.java
View File

@ -38,7 +38,7 @@ public class JobManager implements ConstraintObserver.Notifier {
private final Set<EmptyQueueListener> emptyQueueListeners = new CopyOnWriteArraySet<>(); private final Set<EmptyQueueListener> emptyQueueListeners = new CopyOnWriteArraySet<>();
public JobManager(@NonNull Application application, @NonNull Configuration configuration) { public JobManager(@NonNull Application application, @NonNull Configuration configuration) {
this.executor = configuration.getExecutorFactory().newSingleThreadExecutor("JobManager"); this.executor = configuration.getExecutorFactory().newSingleThreadExecutor("signal-JobManager");
this.jobRunners = new JobRunner[configuration.getJobThreadCount()]; this.jobRunners = new JobRunner[configuration.getJobThreadCount()];
this.jobController = new JobController(application, this.jobController = new JobController(application,
configuration.getJobStorage(), configuration.getJobStorage(),

2
src/org/thoughtcrime/securesms/jobmanager/JobRunner.java
View File

@ -23,7 +23,7 @@ class JobRunner extends Thread {
private final JobController jobController; private final JobController jobController;
JobRunner(@NonNull Application application, int id, @NonNull JobController jobController) { JobRunner(@NonNull Application application, int id, @NonNull JobController jobController) {
super("JobRunner-" + id); super("signal-JobRunner-" + id);
this.application = application; this.application = application;
this.id = id; this.id = id;

2
src/org/thoughtcrime/securesms/logging/PersistentLogger.java
View File

@ -48,7 +48,7 @@ public class PersistentLogger extends Log.Logger {
this.context = context.getApplicationContext(); this.context = context.getApplicationContext();
this.secret = LogSecretProvider.getOrCreateAttachmentSecret(context); this.secret = LogSecretProvider.getOrCreateAttachmentSecret(context);
this.executor = Executors.newSingleThreadExecutor(r -> { this.executor = Executors.newSingleThreadExecutor(r -> {
Thread thread = new Thread(r, "PersistentLogger"); Thread thread = new Thread(r, "signal-PersistentLogger");
thread.setPriority(Thread.MIN_PRIORITY); thread.setPriority(Thread.MIN_PRIORITY);
return thread; return thread;
}); });

19
src/org/thoughtcrime/securesms/util/ThreadUtil.java
View File

@ -1,19 +0,0 @@
package org.thoughtcrime.securesms.util;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadUtil {
public static ExecutorService newDynamicSingleThreadedExecutor() {
ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>());
executor.allowCoreThreadTimeOut(true);
return executor;
}
}