add 分发 master_author 添加字段 subscribe increment， 添加7个表 master_author...

kimi

2020-04-22 5268a2b7dfa556bd6f5a2d5e446cea3ea9940c10

 src/main/java/com/highdatas/mdm/util/TimeTasks.java

@@ -1,16 +1,8 @@
package com.highdatas.mdm.util;



import com.highdatas.mdm.service.DispenseService;

import com.highdatas.mdm.util.pool.MqMessage;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.Scheduled;



import java.io.IOException;

import java.util.Date;

import java.util.concurrent.PriorityBlockingQueue;



/**

 * @author kimi

@@ -23,31 +15,31 @@
@EnableScheduling

@Slf4j

public class TimeTasks {

    @Autowired

    DispenseService dispenseService;

//    @Autowired

//    DispenseService dispenseService;



    @Scheduled(fixedRate=1000 * 10)

    private void configureTasks() {

        PriorityBlockingQueue<Runnable> queue = dispenseService.getQueue();

        if (queue.isEmpty()) {

            return;

        }

        log.info("queue passiveQueueSize: {}", queue.size());

        for (Runnable runnable : queue) {

            if (!(runnable instanceof MqMessage)) {

                continue;

            }

            MqMessage mqMessage = (MqMessage) runnable;

            Date endTime = mqMessage.getEndTime();

            Date now = new Date();

            if (now.after(endTime)) {

                //timeout;

                try {

                    mqMessage.printTimeOut();

                } catch (IOException e) {

                    e.printStackTrace();

                }

            }

        }

    }

//    @Scheduled(fixedRate=1000 * 10)

//    private void configureTasks() {

//        PriorityBlockingQueue<Runnable> queue = dispenseService.getQueue();

//        if (queue.isEmpty()) {

//            return;

//        }

//        log.info("queue passiveQueueSize: {}", queue.size());

//        for (Runnable runnable : queue) {

//            if (!(runnable instanceof MqMessage)) {

//                continue;

//            }

//            MqMessage mqMessage = (MqMessage) runnable;

//            Date endTime = mqMessage.getEndTime();

//            Date now = new Date();

//            if (now.after(endTime)) {

//                //timeout;

//                try {

//                    mqMessage.printTimeOut();

//                } catch (IOException e) {

//                    e.printStackTrace();

//                }

//            }

//        }

//    }

}