Qortal/altcoinj
3
0
Fork 0
mirror of https://github.com/Qortal/altcoinj.git synced 2025-01-31 23:32:16 +00:00
Code Issues Projects Releases Wiki Activity

Allow overriding of the default USER_THREAD executor so all events can be dispatched to a selected thread easily.

Browse Source
This commit is contained in:
Mike Hearn 2013-09-14 23:38:41 +02:00
parent 82037f8f96
commit 3ea3735d4f
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
core/src/main/java/com/google/bitcoin/utils/Threading.java
View File

@ -39,7 +39,10 @@ public class Threading {
* runs without any locks being held. It's intended for the API user to run things on. Callbacks registered by * runs without any locks being held. It's intended for the API user to run things on. Callbacks registered by
* bitcoinj internally shouldn't normally run here, although currently there are a few exceptions. * bitcoinj internally shouldn't normally run here, although currently there are a few exceptions.
*/ */
public static final ExecutorService USER_THREAD; public static Executor USER_THREAD;
// Default value for USER_THREAD.
private static final ExecutorService SINGLE_THREADED_EXECUTOR;
/** /**
* A dummy executor that just invokes the runnable immediately. Use this over * A dummy executor that just invokes the runnable immediately. Use this over
@ -65,7 +68,7 @@ public class Threading {
// means there's a bug in bitcoinj. // means there's a bug in bitcoinj.
checkState(userThread.get() != null && userThread.get() != Thread.currentThread(), checkState(userThread.get() != null && userThread.get() != Thread.currentThread(),
"waitForUserCode() run on user code thread would deadlock."); "waitForUserCode() run on user code thread would deadlock.");
Futures.getUnchecked(USER_THREAD.submit(Callables.returning(null))); Futures.getUnchecked(SINGLE_THREADED_EXECUTOR.submit(Callables.returning(null)));
} }
/** /**
@ -87,7 +90,7 @@ public class Threading {
// from that point onwards. // from that point onwards.
throwOnLockCycles(); throwOnLockCycles();
USER_THREAD = Executors.newSingleThreadExecutor(new ThreadFactory() { SINGLE_THREADED_EXECUTOR = Executors.newSingleThreadExecutor(new ThreadFactory() {
@Nonnull @Override public Thread newThread(@Nonnull Runnable runnable) { @Nonnull @Override public Thread newThread(@Nonnull Runnable runnable) {
Thread t = new Thread(runnable); Thread t = new Thread(runnable);
t.setName("bitcoinj user thread"); t.setName("bitcoinj user thread");
@ -97,6 +100,7 @@ public class Threading {
return t; return t;
} }
}); });
USER_THREAD = SINGLE_THREADED_EXECUTOR;
SAME_THREAD = new Executor() { SAME_THREAD = new Executor() {
@Override @Override
public void execute(@Nonnull Runnable runnable) { public void execute(@Nonnull Runnable runnable) {