实习生小王最近很困扰，明明已经按照网上的教程开启了一个新的线程，在多线程内却出现了各种意想不到的错误。如果你也遇到了和小王类似的问题，不要慌，小王的好朋友心水水同学连夜肝出了这份苍穹多线程使用指南！快来一起瞅瞅吧！

1 错误用法

在开始介绍正确姿势之前，心水水同学列举了一些在苍穹使用多线程时的常见错误用法。

a) 没有在线程中指定上下文

 // 一. a
    @Test
    @TestMethod(3)
    @DisplayName("error01")
    public void error01() {
        new Thread(() -> {
            DBRoute route = DBRoute.of("sys");
            try {
                Long result = DB.query(route, "SELECT FID FROM t_sec_user where phone=?", new Object[]{"17299999999"}, resultSet -> {
                    if (resultSet.next()) {
                        return resultSet.getLong("fid");
                    }
                    return null;
                });
                LOG.info("query result is : {}", result);
            } catch (Exception ex) {
                LOG.error("query error,msg:{}", ex.getMessage(), ex);
            }
        }).start();
    }

启动新线程时，没有指定上下文，访问DB接口时，DB无法根据上下文选择一个数据源进行数据库的访问（ThreadPools已经默认使用了当前请求的上下文）。

b) 在方法内创建线程池

 @Test
    @TestMethod(4)
    @DisplayName("error02")
    public void error02() {
        doWork();
    }
    private void doWork() {
        ExecutorService executor = Executors.newFixedThreadPool(4, new ThreadFactoryImpl("TestThreadPool"));
        executor.submit(new ErrorRunnable2(RequestContext.get()));
    }

在方法内创建线程池，会导致每次访问该方法时都会创建一个新的线程池，过多的线程会可能会导致OOM。其次，操作系统会花费大量的时间用于线程调度，使得执行任务的时间变少，从而导致任务总耗时增加。

c) 使用ThreadLocal完毕后并没有及时清理

static class ErrorRunnable2 implements Runnable {
        private static final ThreadLocal<Object> THREAD_LOCAL = new ThreadLocal<>();
        private final RequestContext context;
        public ErrorRunnable2(RequestContext context) {
            this.context = context;
        }
        @Override
        public void run() {
            RequestContextInfo dbContext = new RequestContextInfo(context.getTenantId(), context.getAccountId());
            try (AutoCloseable closeable = dbContext.setupThreadRequestContext()) {
                DBRoute route = DBRoute.of("sys");
                Long result = DB.query(route, "SELECT FID FROM t_sec_user where phone=?", new Object[]{"17299999999"}, resultSet -> {
                    if (resultSet.next()) {
                        return resultSet.getLong("fid");
                    }
                    return null;
                });
                LOG.info("ErrorRunnable2 : query result is : {}", result);
                THREAD_LOCAL.set(result);
                // do other
                // end
            } catch (Exception ex) {
                LOG.error("ErrorRunnable2: query error,msg:{}", ex.getMessage(), ex);
            }
        }
    }

使用ThreadLocal时，如果使用完毕后没有及时清理ThreadLocal，可能会因为连接池复用线程，线程长时间未释放等原因造成内存泄漏。（ThreadPools接口创建的线程会在线程结束后自动清理该线程的ThreadLocal）

那有没有一种简单的办法能够解决或者避免上面的问题？

下面就开始介绍在苍穹打开多线程的正确方式，让你轻松搞定多线程开发。

2 正确姿势

为了演示方便，心水水同学使用的测试代码均运行在苍穹的单元测试平台。

1.简单示例

@Test
    @TestMethod(1)
    @DisplayName("hello")
    public void hello() {
        ThreadPools.executeOnce("ThreadForTest", () -> {
            while (!Thread.interrupted()) {
                LOG.info("\r\nHello world,\r\ncurrent thread name:{}, \r\nrc:{}",
                        Thread.currentThread().getName(), RequestContextInfo.get());
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException ignored) {
                }
            }
        });
    }

运行后可以在控制台看见类似的日志：

在使用ThreadPools创建新线程时，使用当前登陆账户的租户以及账套信息。此时打开monitor，能进一步获取到当前线程运行的traceId以及当前堆栈信息。

有了traceId，就可以很方便的在日志系统中根据traceId查找相关的日志，进行问题排查。

2.更多介绍

ThreadPools还提供了其它的静态方法供大家调用：

 // 和示例中代码类似,执行一次runnable，该方法允许用户传入自定义appId，打印日志时会记录上对应的appId  
ThreadPools.executeOnce(name,runnable,appId);  
// 执行一次runnable，该方法允许用户传入自定义或者当前线程的OperationContext  
ThreadPools.executeOnce(name, runnable, operationContext);  
// 返回一个指定线程数量的ExecutorService。  
// 线程池任务队列数默认为100000，也可通过在MC中配置threadpool.fix.maxqueue.size来自定义线程池的任务队列数  
// 当任务队列满了再提交任务则会进入线程池拒绝策略。  
ThreadPools.newExecutorService(name, 3);  
// 返回一个可缓存的线程池，核心线程数为3，最大线程数为1000  
// 该线程池任务队列为0，如果当前活跃线程已经达到1000，后续提交的任务会直接进入线程池拒绝策略  
ThreadPools.newCachedExecutorService(name);  
// 返回一个可缓存的线程池，核心线程数为1，最大线程数为20  
// 该线程池任务队列为0，如果当前活跃线程已经达到20，后续提交的任务会直接进入线程池拒绝策略  
ThreadPools.newCachedExecutorService(name, 1, 20);  
// 默认的线程池拒绝策略  
// 当线程池中活跃的数量小于最大数量的0.9时，会使用线程池空闲线程运行，  
// 否则会等待并重试，每一次重试的等待时间为: 100(ms)*重试次数 ,当重试达到100次时线程池会抛出异常。（悄悄计算过，最大时间为505秒

上面是常用的几个方法，但是内置的策略或者参数一定满足不了全部情况。

所以想要自己封装ExecutorService并加入苍穹全家桶也很简单，具体操作如下：

// 自定义及初始化好ExecutorService，再使用ThreadLifeCycleManager的wrapExecutorService方法包装
ExecutorService custom = Executors.newScheduledThreadPool(1, new ThreadFactoryImpl(name));  
custom = ThreadLifeCycleManager.wrapExecutorService(custom);

返回来的ExecutorService就可以和普通的线程池一样使用了。

以上就是苍穹多线程使用指南，如果还有其它问题的同学可以点入金蝶云社区提问~~

https://club.kdcloud.com/topics

#往期推荐#

# 1分钟了解苍穹自定义文件存储服务

# 苍穹平台事务，你知道多少？

# 还在为大数据量搜索慢而烦恼？那就试试它吧！

# 什么？竟然还有人不知道苍穹Monitor

# 看完这份攻略，“苍穹分布式锁”拿捏得稳稳的

# 苍穹分布式ID，你知多少？

更多精彩内容，“码”上了解！↓

为了这份线程池使用指南，我鸽了隔壁女神的约会

为了这份线程池使用指南，我鸽了隔壁女神的约会

恭喜您！