This is an automated email from the ASF dual-hosted git repository. yong pushed a commit to branch branch-4.16 in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit d3f8aa3389cc93f86a87f39368e1ddcbeaff9430 Author: houxiaoyu <[email protected]> AuthorDate: Wed Apr 12 22:37:52 2023 +0800 Cleanup CbThreadFactory (#3907) * Cleanup CbThreadFactory * checkstyle (cherry picked from commit 912896deb2e748389e15e74c37539b2ff36302c7) --- .../src/main/java/org/apache/bookkeeper/bookie/Journal.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java index 4fd2c2f28d..99eaa23819 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/Journal.java @@ -41,7 +41,6 @@ import java.nio.channels.FileChannel; import java.util.ArrayList; import java.util.Collections; import java.util.List; -import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import org.apache.bookkeeper.bookie.LedgerDirsManager.NoWritableLedgerDirException; import org.apache.bookkeeper.bookie.stats.JournalStats; @@ -555,18 +554,6 @@ public class Journal extends BookieCriticalThread implements CheckpointSource { } } - private static class CbThreadFactory implements ThreadFactory { - private int counter = 0; - private String threadBaseName = "bookie-journal-callback"; - - public Thread newThread(Runnable r) { - int threadOrdinal = counter++; - Thread t = new Thread(r, threadBaseName + "-" + threadOrdinal); - ThreadRegistry.register(threadBaseName, threadOrdinal, t.getId()); - return t; - } - } - static final int PADDING_MASK = -0x100; static void writePaddingBytes(JournalChannel jc, ByteBuf paddingBuffer, int journalAlignSize)
