@Override
            public void run() {
                countDownLatch.countDown();
                try {
                    countDownLatch.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                long start = System.currentTimeMillis();
                RpcInvokeContext.setContext(context);
                long now = System.currentTimeMillis();
                int i = 0;
                while (now - start < 100) {
                    now = System.currentTimeMillis();
                    i++;
                    RpcInvokeContext.getContext().addCustomHeader(i + "", i + "");
                    try {
                        new HashMap<>().putAll(RpcInvokeContext.getContext().getCustomHeader());
                    } catch (Exception e) {
                        System.out.println(i);
                        throw e;
                    }
                }

            }
@author <a href="mailto:zhanggeng.zg@antfin.com">GengZhang</a>
core/api/src/test/java/com/alipay/sofa/rpc/context/RpcInvokeContextTest.java