定時任務返回結果給方法


定時任務返回結果給方法

示例代碼:

存在一些小問題,list會添加重復的數據,后面用到再優化一下

package com.sucsoft.video.service.develop;

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * 輪播畫面定時器
 */
@Service
public class VsCarouselTimerService {

    private static ScheduledExecutorService pool = Executors.newScheduledThreadPool(5);
    private static final Logger logger = Logger.getLogger(VsCarouselTimerService.class);
    private static String url = "";

    private static Map map = new HashMap();
    private List<Map> list = new ArrayList<Map>();

    @Autowired
    private RestTemplate restTemplate;

    /**
     * 每5分鍾請求一次, 延遲1分鍾開始執行
     * @param id
     */
    public void requestStream(String id) {
        // 防止重復創建線程
        if(Thread.currentThread().isAlive()) {
            this.pool.shutdown();
            pool = Executors.newScheduledThreadPool(5);
        }

        pool.scheduleAtFixedRate(() -> {
            try {
                map = restTemplate.getForObject(url, Map.class);
                list.add(map);
            } catch (Exception e) {
                logger.error(e);
            }
        }, 1, 300, TimeUnit.SECONDS);
    }

    /**
     * 轉發流給前端
     * @return
     */
    public List<Map> forwardStream() {

        return list;
    }

}


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM