1

zj

2026-05-21 31e6203a5bb778ad9d1c599171606c89c8edd3a3

 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;