lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

AnonymousVirtualExecutor

Browse Source
This commit is contained in:
redkale
2023-10-18 08:37:00 +08:00
parent cde5b80c2d
commit d743d7e90d
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/redkale/util/AnonymousVirtualExecutor.java
View File

@@ -4,7 +4,6 @@
//package org.redkale.util; //package org.redkale.util;
// //
//import java.util.concurrent.*; //import java.util.concurrent.*;
//import java.util.concurrent.atomic.AtomicInteger;
//import java.util.function.Function; //import java.util.function.Function;
// //
///** ///**
@@ -16,11 +15,10 @@
// @Override // @Override
// public ExecutorService apply(String threadNameFormat) { // public ExecutorService apply(String threadNameFormat) {
// final ThreadFactory factory = Thread.ofVirtual().factory(); // final ThreadFactory factory = Thread.ofVirtual().factory();
// final AtomicInteger counter = new AtomicInteger(); // final String threadName = String.format(threadNameFormat, "Virtual");
// return Executors.newThreadPerTaskExecutor(r -> { // return Executors.newThreadPerTaskExecutor(r -> {
// Thread t = factory.newThread(r); // Thread t = factory.newThread(r);
// int c = counter.incrementAndGet(); // t.setName(threadName);
// t.setName(String.format(threadNameFormat, "Virtual-" + (c < 10 ? ("00" + c) : (c < 100 ? ("0" + c) : c))));
// return t; // return t;
// }); // });
// } // }

2
src/main/java/org/redkale/util/Utility.java
View File

File diff suppressed because one or more lines are too long