1

zj

2026-05-13 f7bde8a9d9bf8e3c67c0912cbd8c50fe4f7097aa

 trading-order-service/src/main/java/com/yami/trading/EmailServer.java

@@ -59,28 +59,19 @@
     */
    public void run() {
        while (true) {

            try {
                EmailMessage item = EmailMessageQueue.poll();

                if (item != null) {
                   System.out.println("邮寄地址：" + item.getTomail());
                    taskExecutor.execute(new HandleRunner(item));
                }
                else {
                   /*
                    * 限速，最多1秒20个
                    */
                if (null!=item) {
                    logger.info("邮寄地址：" + item.getTomail()+"内容:"+item.getContent());
                    internalEmailSenderService.send(item);
                }else {
                    ThreadUtils.sleep(50);
                }

            } catch (Throwable e) {
                logger.error("EmailServer taskExecutor.execute() fail", e);

            }
        }
    }

    public class HandleRunner implements Runnable {
        private EmailMessage item;