Java Runnable、Callable、FutureTask异步实践

异步理解

异步主要是用于一些用户体验上，示例如 ajax技术，防止主线程阻塞，非UI层面的应用场景可以用作 日志记录等IO耗时动作或者一些一致性要求较低的逻辑部分。异步是开启一个新线程来处理

Java里多线程里可以用到的有Thread,Runable,FutureTask(有返回值)

代码示例部分

看下代码执行后的线程ID变化和系统时间戳变化,异步会启动一个新线程处理

Runnable

@RequestMapping("/t8")
public String async8(){
	System.out.println(System.currentTimeMillis()+"主线程开始："+Thread.currentThread().getId());
	Runnable runnable = ()->{
		System.out.println(System.currentTimeMillis()+"异步线程开始："+Thread.currentThread().getId());
		try {
			Thread.sleep(2000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(System.currentTimeMillis()+"异步线程结束："+Thread.currentThread().getId());
	};
	new Thread(runnable).start();
	System.out.println(System.currentTimeMillis()+"主线程结束："+Thread.currentThread().getId());
	return "I like China!"+System.currentTimeMillis();
}

Callable

Callable 异步模式

@RequestMapping("/t10")
public String async10() throws ExecutionException, InterruptedException {
	System.out.println(System.currentTimeMillis()+"主线程开始："+Thread.currentThread().getId());
	Callable<String> callable= ()->{
		System.out.println(System.currentTimeMillis()+"异步线程开始："+Thread.currentThread().getId());
		Thread.sleep(3000);
		System.out.println(System.currentTimeMillis()+"异步线程结束："+Thread.currentThread().getId());
		return "I like China!";
	};
	FutureTask<String> futureTask = new FutureTask<>(callable);
	new Thread(futureTask).start();
	//System.out.println(futureTask.get());
	System.out.println(System.currentTimeMillis()+"主线程结束："+Thread.currentThread().getId());
	return "I like China!"+System.currentTimeMillis();
}

Callable 同步模式

把上方代码的注释地方打开,观察下方运行结果

@Async注解

总结

异步主要是为了提升用户体验，但异步主要有2点，1.异步执行 2.获取异步执行结果，只要能能理解这两点，剩下就是如何使用技术实现