Skip to content

Commit 359ba2e

Browse files
authored
Merge pull request #2561 from swastik959/th
added ability to inject threads
2 parents a486048 + 13204fd commit 359ba2e

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

util/src/main/java/io/kubernetes/client/util/Threads.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,9 +17,13 @@
1717
import java.util.concurrent.atomic.AtomicInteger;
1818

1919
public class Threads {
20+
private static ThreadFactory defaultFactory = Executors.defaultThreadFactory();
21+
// Users can inject their own thread
22+
public static void setDefaultThreadFactory(ThreadFactory factory) {
23+
defaultFactory = factory;
24+
}
2025

2126
public static ThreadFactory threadFactory(String format) {
22-
final ThreadFactory defaultFactory = Executors.defaultThreadFactory();
2327
final AtomicInteger threadNumber = new AtomicInteger(1);
2428
return r -> {
2529
Thread thread = defaultFactory.newThread(r);

0 commit comments

Comments
 (0)