Qortal/altcoinj
1
0
Fork 1
mirror of https://github.com/Qortal/altcoinj.git synced 2025-11-02 05:27:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

ContextPropagatingThreadFactory: more features

Browse Source
This commit is contained in:
Mike Hearn
2015-07-14 13:15:03 +02:00
parent 97cf1abd79
commit e03fdde6b0
1 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
core/src/main/java/org/bitcoinj/utils/ContextPropagatingThreadFactory.java
View File

@@ -1,20 +1,27 @@
package org.bitcoinj.utils;
import com.google.common.base.*;
import org.bitcoinj.core.*;
import org.slf4j.*;
import java.util.concurrent.*;
import static com.google.common.base.Preconditions.checkNotNull;
/**
* A {@link java.util.concurrent.ThreadFactory} that propagates a {@link org.bitcoinj.core.Context} from the creating
* thread into the new thread. This factory creates daemon threads.
*/
public class ContextPropagatingThreadFactory implements ThreadFactory {
private static final Logger log = LoggerFactory.getLogger(ContextPropagatingThreadFactory.class);
private final String name;
private final int priority;
public ContextPropagatingThreadFactory(String name, int priority) {
this.name = name;
this.priority = priority;
}
public ContextPropagatingThreadFactory(String name) {
this.name = checkNotNull(name);
this(name, Thread.NORM_PRIORITY);
}
@Override
@@ -23,11 +30,20 @@ public class ContextPropagatingThreadFactory implements ThreadFactory {
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
Context.propagate(context);
r.run();
try {
Context.propagate(context);
r.run();
} catch (Exception e) {
log.error("Exception in thread", e);
Throwables.propagate(e);
}
}
}, name);
thread.setPriority(priority);
thread.setDaemon(true);
Thread.UncaughtExceptionHandler handler = Threading.uncaughtExceptionHandler;
if (handler != null)
thread.setUncaughtExceptionHandler(handler);
return thread;
}
}