Java 多线程编程:使用 Callable 和 Future 创建线程
以下是一个使用 Callable 和 Future 创建线程的 Java 多线程代码示例:
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableExample {
public static void main(String[] args) throws InterruptedException, ExecutionException {
ExecutorService executor = Executors.newSingleThreadExecutor(); // 创建线程池
Callable<String> callable = new MyCallable(); // 创建Callable任务
Future<String> future = executor.submit(callable); // 提交任务并获取Future对象
System.out.println('等待任务执行结果...');
String result = future.get(); // 获取任务执行结果,这是一个阻塞方法,直到任务执行完成才会返回结果
System.out.println('任务执行结果:' + result);
executor.shutdown(); // 关闭线程池
}
}
class MyCallable implements Callable<String> {
@Override
public String call() throws Exception {
Thread.sleep(3000); // 模拟耗时操作
return 'Hello, World!';
}
}
在这个示例中,我们创建了一个 Callable 任务 (MyCallable),并将其提交给一个线程池 (ExecutorService)。线程池会返回一个 Future 对象,我们可以使用它来获取任务的执行结果。在主线程中,我们调用 Future 对象的 get 方法来获取结果,这是一个阻塞方法,直到任务执行完成才会返回结果。最后,我们关闭线程池。
原文地址: https://www.cveoy.top/t/topic/ogi8 著作权归作者所有。请勿转载和采集!