diff --git a/ethereumj-core/build.gradle b/ethereumj-core/build.gradle index f04354bc42..e92792a849 100644 --- a/ethereumj-core/build.gradle +++ b/ethereumj-core/build.gradle @@ -120,6 +120,8 @@ dependencies { compile "org.ethereum:solcJ-all:0.4.19" // Solidity Compiler win/mac/linux binaries + compile "com.google.guava:guava:24.1-jre" + compile "com.cedarsoftware:java-util:1.8.0" // for deep equals compile "org.javassist:javassist:3.15.0-GA" compile "org.slf4j:slf4j-api:${slf4jVersion}" diff --git a/ethereumj-core/src/main/java/org/ethereum/mine/AnyFuture.java b/ethereumj-core/src/main/java/org/ethereum/mine/AnyFuture.java index b240c41fd9..23d69eaf9f 100644 --- a/ethereumj-core/src/main/java/org/ethereum/mine/AnyFuture.java +++ b/ethereumj-core/src/main/java/org/ethereum/mine/AnyFuture.java @@ -37,7 +37,7 @@ public class AnyFuture extends AbstractFuture { public synchronized void add(final ListenableFuture f) { if (isCancelled() || isDone()) return; - f.addListener(() -> futureCompleted(f), MoreExecutors.sameThreadExecutor()); + f.addListener(() -> futureCompleted(f), MoreExecutors.directExecutor()); futures.add(f); } diff --git a/ethereumj-core/src/main/java/org/ethereum/mine/BlockMiner.java b/ethereumj-core/src/main/java/org/ethereum/mine/BlockMiner.java index ed36f9fc12..5c5d9584bd 100644 --- a/ethereumj-core/src/main/java/org/ethereum/mine/BlockMiner.java +++ b/ethereumj-core/src/main/java/org/ethereum/mine/BlockMiner.java @@ -279,7 +279,7 @@ protected void restartMining() { } catch (Exception e) { logger.warn("Exception during mining: ", e); } - }, MoreExecutors.sameThreadExecutor()); + }, MoreExecutors.directExecutor()); } } fireBlockStarted(newMiningBlock); diff --git a/ethereumj-core/src/test/java/org/ethereum/mine/FutureTest.java b/ethereumj-core/src/test/java/org/ethereum/mine/FutureTest.java index a38bec47e1..ad31c3d78b 100644 --- a/ethereumj-core/src/test/java/org/ethereum/mine/FutureTest.java +++ b/ethereumj-core/src/test/java/org/ethereum/mine/FutureTest.java @@ -52,7 +52,7 @@ public void interruptTest() throws InterruptedException { } catch (ExecutionException e) { throw new RuntimeException(e); } - }, MoreExecutors.sameThreadExecutor()); + }, MoreExecutors.directExecutor()); Thread.sleep(1000); future.cancel(true);