import javax.enterprise.concurrent.ManagedExecutorService; import javax.enterprise.concurrent.ManagedThreadFactory; import java.util.concurrent.Callable; import java.util.concurrent.Future; public class ConcurrentExample { private ManagedExecutorService executorService; private ManagedThreadFactory threadFactory; public ConcurrentExample() { } public void executeTask() { executorService.execute(() -> { }); } public <T> Future<T> submitTask(Callable<T> task) { return executorService.submit(task); } public void createThread() { Thread newThread = threadFactory.newThread(() -> { }); newThread.start(); } }


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