package com.nq.config;
|
|
import com.nq.dao.RealTimeMapper;
|
import com.nq.dao.StockFuturesMapper;
|
import com.nq.dao.StockIndexMapper;
|
import com.nq.dao.StockMapper;
|
import com.nq.pojo.Stock;
|
import com.nq.utils.stock.sina.StockApi;
|
|
import java.util.List;
|
import java.util.concurrent.ArrayBlockingQueue;
|
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.TimeUnit;
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
public class StockPoll {
|
|
private ThreadPoolExecutor pool;
|
|
@PostConstruct
|
public void initPool() {
|
this.pool = new ThreadPoolExecutor(50, 70, 20L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(240));
|
this.pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
|
}
|
|
|
}
|
