public class Sync {
public static void main(String[] args) {
FutureTask futureTask = new FutureTask();
Future<String> future = futureTask.submitaaa("异步调用开始");
System.out.println("-----------主线程------------");
}
}
//开启新的线程，实现异步
class FutureTask{
public Future<String> submitaaa(String s){
return Executors.newCachedThreadPool().submit(new Callable<String>() {
@Override
public String call() throws Exception {
Thread.sleep(10000);
Busi busi = new Busi();
;
return busi.getString(s);
}
});
}
}
//需要异步处理的操作
class Busi{
public String getString(String s) {
System.out.println("-------Busi--------");
return s;
}
}
以上是使用多线程实现的异步调用