blog/slf4j-mdc-muti-thread
2
0
Fork 0
Code Pull Requests Releases Activity

更新测试案列

Browse Source
This commit is contained in:
xking 2023-07-06 00:04:01 +08:00
parent d36a9267c8
commit adfe6eb0ab
Signed by: chenkuangwei
GPG Key ID: 931C79A9747F5F82
2 changed files with 19 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -14,7 +14,7 @@
<dependency> <dependency>
<groupId>org.apache.logging.log4j</groupId> <groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId> <artifactId>log4j-slf4j-impl</artifactId>
<version>2.10.0</version> <version>2.20.0</version>
</dependency> </dependency>
</dependencies> </dependencies>

39
src/main/java/cn/wudashan/Main.java
View File

@ -5,11 +5,14 @@ import cn.wudashan.util.MDCUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.util.Random;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.stream.Stream;
/** /**
* 主函数 * 主函数
*
* @author wudashan * @author wudashan
*/ */
public class Main { public class Main {
@ -19,32 +22,26 @@ public class Main {
public static void main(String[] args) { public static void main(String[] args) {
// 入口传入请求ID
MDCUtil.putRequestId();
// 主线程打印日志 Stream.generate(() -> new Random().nextInt(10)).distinct().limit(10)
logger.debug("log in main thread"); .parallel().forEach(e -> {
// 入口传入请求ID
MDCUtil.putRequestId();
// 主线程打印日志
logger.debug("{} log in main thread", e);
// 异步线程打印日志，用MDCRunnable装饰Runnable // 异步线程打印日志，用MDCRunnable装饰Runnable
new Thread(new MDCRunnable(new Runnable() { new Thread(new MDCRunnable(() -> logger.debug("{} log in other thread", e))).start();
@Override
public void run() {
logger.debug("log in other thread");
}
})).start();
// 异步线程池打印日志，用MDCRunnable装饰Runnable // 异步线程池打印日志，用MDCRunnable装饰Runnable
EXECUTOR.execute(new MDCRunnable(new Runnable() { EXECUTOR.execute(new MDCRunnable(() -> logger.debug("{} log in other thread pool", e)));
@Override
public void run() { // 出口移除请求ID
logger.debug("log in other thread pool"); MDCUtil.removeRequestId();
}
})); });
EXECUTOR.shutdown(); EXECUTOR.shutdown();
// 出口移除请求ID
MDCUtil.removeRequestId();
} }
} }