mirrors/bitcoinj
1
0
Fork 0
mirror of https://github.com/bitcoinj/bitcoinj.git synced 2025-03-10 00:09:31 +01:00
Code Issues Projects Releases Packages Wiki Activity

TestWithPeerGroup: remove unneeded use of ListeningScheduledExecutorService

Browse source 
There is no longer a need to decorate `ScheduledThreadPoolExecutor` to support
`ListeningScheduledExecutorService` since `PeerGroup` no longer uses it.
This commit is contained in:
Sean Gilligan 2023-10-01 11:57:07 -07:00 • committed by Andreas Schildbach
parent 5513f7dff0
commit 1b63903ad3
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
integration-test/src/test/java/org/bitcoinj/testing/TestWithPeerGroup.java
View file

@ -16,8 +16,6 @@
package org.bitcoinj.testing;
import com.google.common.util.concurrent.ListeningScheduledExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import org.bitcoinj.base.internal.TimeUtils;
import org.bitcoinj.core.BloomFilter;
import org.bitcoinj.core.MemoryPoolMessage;
@ -40,6 +38,7 @@ import org.junit.rules.Timeout;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.time.Duration;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.Semaphore;
@ -115,8 +114,8 @@ public class TestWithPeerGroup extends TestWithNetworkConnections {
private PeerGroup createPeerGroup(final ClientConnectionManager manager) {
return new PeerGroup(UNITTEST, blockChain, manager, PeerGroup.DEFAULT_BLOOM_FILTER_FP_RATE) {
@Override
protected ListeningScheduledExecutorService createPrivateExecutor() {
return MoreExecutors.listeningDecorator(new ScheduledThreadPoolExecutor(1, new ContextPropagatingThreadFactory("PeerGroup test thread")) {
protected ScheduledExecutorService createPrivateExecutor() {
return new ScheduledThreadPoolExecutor(1, new ContextPropagatingThreadFactory("PeerGroup test thread")) {
@Override
public ScheduledFuture<?> schedule(final Runnable command, final long delay, final TimeUnit unit) {
if (!blockJobs)
@ -127,7 +126,7 @@ public class TestWithPeerGroup extends TestWithNetworkConnections {
jobBlocks.acquireUninterruptibly();
}, 0 /* immediate */, unit);
}
});
};
}
};
}