ScheduledExecutorService 定时器用法

1，如果只是想简单的写个定时任务，比如10分钟跑一次，那么ScheduledExecutorService是比较方便的，下面举个简单的例子

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledFuture;

import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class CrawlerRun {

   private static final Logger logger = LoggerFactory.getLogger(CrawlerRun.class);

   public static void main(String[] args) {

      ScheduledExecutorService service = Executors.newScheduledThreadPool(8);//先定义8个线程空间

      final ScheduledFuture<?> future = service.scheduleAtFixedRate(new CrawlerTest(), 0,10,

                 TimeUnit.MINUTES);//CrawlerTest()是一个实现Runnable接口的类，会自动运行里面的run()方法，0的意思就是启动等待时间，这里就是直接运行，
                                 10是10分钟，要是想小时，就把TimeUnit.MINUTES换成 TimeUnit.HOURS

      //使用1个线程

         Thread t= new Thread(new Runnable() {

                public void run() {

                    try {

                        future.get();

                    } catch (Exception e) {

                        logger.error(e.getCause().getMessage(), e.getCause());//日志信息输出

                        future.cancel(false);//关闭线程

                    }

                }

        });

        t.start() ;

   }

}

2，如果想早上8点到晚上8点采集（期间还是10分钟跑一次），别的时间不采集，那就要在CrawlerTest()里面run()方法做判断

import java.util.Calendar;

public void run() {

        try {

            Calendar ca=Calendar.getInstance();

            int hour = ca.get(Calendar.HOUR_OF_DAY) ;//获取当时时间数

            if(hour <8 || hour >20) return ;

            this.Crawler2();

        } catch (ClientProtocolException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

3，如果想指定就8点，12点，16点，20点采集，别的时间都不采集，那就要加判断

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledFuture;

import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class CrawlerRun {

   private static final Logger logger = LoggerFactory.getLogger(CrawlerRun.class);

   private static long delayTime(long currentTime , String campareDateStr) {

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        Date date = new Date() ; 

        String str = TimeFormat.getYearMonthDate();

        str = str.replaceAll("00:00:00", campareDateStr) ;

        try {

            date = sdf.parse(str) ;

        } catch (ParseException e1) {

            e1.printStackTrace();

        }

        long dateMillis = date.getTime() ;

        return dateMillis - currentTime ;

    }

   public static void main(String[] args) {

        long currentTime = System.currentTimeMillis() ;

        long realDelayTime = 0 ;

        long delayTime = CrawlerRun.delayTime(currentTime, "08:00:00") ;

        long delayTime2= CrawlerRun.delayTime(currentTime, "12:00:00") ;

        long delayTime3= CrawlerRun.delayTime(currentTime, "16:00:00") ;

        long delayTime4= CrawlerRun.delayTime(currentTime, "20:00:00") ;

        List<Long> list = new ArrayList<Long>() ;

        list.add(delayTime) ;

        list.add(delayTime2) ;

        list.add(delayTime3) ;

        list.add(delayTime4) ;

        Collections.sort(list);

        for (Long time : list) {

            if(time < 0 ) continue ;

            else{

                realDelayTime = time;

                break;

                }

        }

      ScheduledExecutorService service = Executors.newScheduledThreadPool(8);//先定义8个线程空间

     final ScheduledFuture<?> future = service.scheduleAtFixedRate(new CrawlerTest(), realDelayTime/1000, 4*60*60,

                 TimeUnit.SECONDS);

      //使用1个线程

         Thread t= new Thread(new Runnable() {

                public void run() {

                    try {

                        future.get();

                    } catch (Exception e) {

                        logger.error(e.getCause().getMessage(), e.getCause());//日志信息输出

                        future.cancel(false);//关闭线程

                    }

                }

        });

        t.start() ;

   }

}

巴特西

ScheduledExecutorService 定时器用法

最新文章

热门文章