Add some logs.

bernardladenthin · Mar 27, 2024 · 161c7b2 · 161c7b2
1 parent 6200615
commit 161c7b2
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/main/java/net/ladenthin/bitcoinaddressfinder/ConsumerJava.java b/src/main/java/net/ladenthin/bitcoinaddressfinder/ConsumerJava.java
@@ -139,7 +139,9 @@ public void startConsumer() {
         for (int i = 0; i < consumerJava.threads; i++) {
             consumers.add(consumeKeysExecutorService.submit(
                     () -> {
+                        logger.info("start consumeKeysRunner");
                         consumeKeysRunner();
+                        logger.info("end consumeKeysRunner");
                         return null;
                     }));
         }
@@ -178,6 +180,7 @@ private void consumeKeysRunner() {
     }
 
     void consumeKeys(ByteBuffer threadLocalReuseableByteBuffer) throws MnemonicException.MnemonicLengthException {
+        logger.trace("consumeKeys");
         PublicKeyBytes[] publicKeyBytesArray = keysQueue.poll();
         while (publicKeyBytesArray != null) {
             for (PublicKeyBytes publicKeyBytes : publicKeyBytesArray) {
@@ -322,6 +325,7 @@ public void consumeKeys(PublicKeyBytes[] publicKeyBytes) throws InterruptedExcep
 
     @Override
     public void interrupt() {
+        logger.debug("start interrupt");
         shouldRun.set(false);
         scheduledExecutorService.shutdown();
         consumeKeysExecutorService.shutdown();
@@ -330,6 +334,7 @@ public void interrupt() {
         } catch (InterruptedException ex) {
             throw new RuntimeException(ex);
         }
+        logger.debug("finish interrupt");
     }
 
     @VisibleForTesting