private static final Logger LOGGER = LoggerFactory.getLogger(AsyncService.class);

// 简单版本

@Async

public void asyncTaskA() {

LOGGER.info(“asyncTaskA 异步方法执行.”);

}

// 入参类型，此处将调用者(线程)的MDC信息传入，主要是保持日志输出时，两个线程有同样的traceId

@Async

public void asyncTaslB(Map<String, String> contextMap) {

MDC.setContextMap(contextMap);

LOGGER.info(“asyncTaskB 异步方法执行.”);

}

// 线程执行后计数器减1

@Async

public void asyncTaskC(CountDownLatch cdl) {

LOGGER.info(“asyncTaskC 异步方法执行.”);

try {

TimeUnit.SECONDS.sleep(2);

} catch (InterruptedException e) {

e.printStackTrace();

}

cdl.countDown();

}

// 有返回参数类型

@Async

public Future asyncTaskD(String message) {

LOGGER.info(“asyncTaskD 异步方法执行.”);

return new AsyncResult(“@” + message);

}

}

4：异步调用

package com.nobody.controller;

import java.util.concurrent.ExecutionException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import com.nobody.domain.AsyncService;

@RestController

@RequestMapping(“demo”)

public class DemoController {

private static final Logger LOGGER = LoggerFactory.getLogger(DemoController.class);

@Autowired

private AsyncService asyncService;

@GetMapping(“test”)

public void test() throws InterruptedException, ExecutionException {

asyncService.asyncTaskA();

LOGGER.info(“主线程执行…”);

}

}

输出结果：

package com.nobody.controller;

import java.util.UUID;

import java.util.concurrent.ExecutionException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.slf4j.MDC;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import com.nobody.domain.AsyncService;

@RestController

@RequestMapping(“demo”)

public class DemoController {

private static final Logger LOGGER = LoggerFactory.getLogger(DemoController.class);

@Autowired

private AsyncService asyncService;

@GetMapping(“test”)

public void test() throws InterruptedException, ExecutionException {

MDC.put(“traceId”, UUID.randomUUID().toString().replaceFirst(“-”, “”));

asyncService.asyncTaskB(MDC.getCopyOfContextMap());

LOGGER.info(“主线程执行…”);

}

}

输出结果：

package com.nobody.controller;

import java.util.concurrent.CountDownLatch;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import com.nobody.domain.AsyncService;

@RestController

@RequestMapping(“demo”)

public class DemoController {

private static final Logger LOGGER = LoggerFactory.getLogger(DemoController.class);

@Autowired

private AsyncService asyncService;

@GetMapping(“test”)

public void test() throws InterruptedException, ExecutionException {

CountDownLatch cdl = new CountDownLatch(2);

asyncService.asyncTaskC(cdl);

asyncService.asyncTaskC(cdl);

try {

// 等等两个线程执行后，再继续下面的执行，如果超过5s则不等待

cdl.await(5, TimeUnit.SECONDS);

} catch (InterruptedException e) {

e.printStackTrace();

}

LOGGER.info(“主线程执行…”);

}

}

输出结果：

package com.nobody.controller;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.Future;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import com.nobody.domain.AsyncService;

@RestController

@RequestMapping(“demo”)

public class DemoController {

private static final Logger LOGGER = LoggerFactory.getLogger(DemoController.class);

@Autowired

private AsyncService asyncService;

@GetMapping(“test”)

public void test() throws InterruptedException, ExecutionException {

Future future = asyncService.asyncTaskD(“Mr.nobody”);

LOGGER.info(“future result:” + future.get());

自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，真正体系化！

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！

如果你觉得这些内容对你有帮助，可以扫码获取！！（备注Java获取）

总结

就写到这了，也算是给这段时间的面试做一个总结，查漏补缺，祝自己好运吧，也希望正在求职或者打算跳槽的 程序员看到这个文章能有一点点帮助或收获，我就心满意足了。多思考，多问为什么。希望小伙伴们早点收到满意的offer! 越努力越幸运！

金九银十已经过了，就目前国内的面试模式来讲，在面试前积极的准备面试，复习整个 Java 知识体系将变得非常重要，可以很负责任的说一句，复习准备的是否充分，将直接影响你入职的成功率。但很多小伙伴却苦于没有合适的资料来回顾整个 Java 知识体系，或者有的小伙伴可能都不知道该从哪里开始复习。我偶然得到一份整理的资料，不论是从整个 Java 知识体系，还是从面试的角度来看，都是一份含技术量很高的资料。

《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
点帮助或收获，我就心满意足了。多思考，多问为什么。希望小伙伴们早点收到满意的offer! 越努力越幸运！**

金九银十已经过了，就目前国内的面试模式来讲，在面试前积极的准备面试，复习整个 Java 知识体系将变得非常重要，可以很负责任的说一句，复习准备的是否充分，将直接影响你入职的成功率。但很多小伙伴却苦于没有合适的资料来回顾整个 Java 知识体系，或者有的小伙伴可能都不知道该从哪里开始复习。我偶然得到一份整理的资料，不论是从整个 Java 知识体系，还是从面试的角度来看，都是一份含技术量很高的资料。

[外链图片转存中…(img-V8E5t13Z-1713670503049)]

《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！