import org.jboss.threads.QueueExecutor; import org.jboss.threads.ThreadFactoryBuilder; import java.util.concurrent.Executor; public class JBossConcurrencyExample { public static void main(String[] args) { Executor executor = createExecutor(); executor.execute(() -> { System.out.println("Hello from concurrent task!"); }); if (executor instanceof AutoCloseable) { try { ((AutoCloseable) executor).close(); } catch (Exception e) { e.printStackTrace(); } } } private static Executor createExecutor() { ThreadFactoryBuilder tfb = new ThreadFactoryBuilder(); tfb.setNamePattern("concurrent-thread-%d"); tfb.setDaemon(true); return new QueueExecutor(10, 10, tfb.build()); } }


上一篇:
下一篇:
切换中文