定時任務返回結果給方法
示例代碼:
存在一些小問題,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;
}
}