多线程－ScheduledExecutorService_scheduledexecutorservice 多线程

转载：　http://blog.csdn.net/tsyj810883979/article/details/8481621　

package cn.stu;
 
import java.text.DateFormat;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
 
public class Main {
	
	static int count; 
	
	public static void main(String[] args){
		
	    final ScheduledExecutorService  executor = Executors.newScheduledThreadPool(1);
	    
//	    fixedDelay(executor);
	    fixedRate(executor);
	}
 
	/**
	 * 
	* @Title: fixedRate 
	* @Description: TODO   到了时间点就走， 订死的时间处理业务。 
	* @param @param executor    设定文件 
	* @return void    返回类型 
	* @throws
	 */
	private static void fixedRate(final ScheduledExecutorService executor){
	    long oneDay = 24 * 60 * 60 * 1000;  
	    long initDelay  = getTimeMillis("16:19:00") - System.currentTimeMillis();  
	    initDelay = initDelay > 0 ? initDelay : oneDay + initDelay;  
	  
	    executor.scheduleAtFixedRate(  
	            new Runnable() {
					
					@Override
					public void run() {
						 
						System.out.println("到点执行了......");
						
						executor.shutdown();
					}
				},  
	            initDelay,  
	            oneDay,  
	            TimeUnit.MILLISECONDS);
		
	}
	
	
    /** 
     * 获取指定时间对应的毫秒数 
     * @param time "HH:mm:ss" 
     * @return 
     */  
    private static long getTimeMillis(String time) {  
        try {  
            DateFormat dateFormat = new SimpleDateFormat("yy-MM-dd HH:mm:ss");  
            DateFormat dayFormat = new SimpleDateFormat("yy-MM-dd");  
            Date curDate = dateFormat.parse(dayFormat.format(new Date()) + " " + time);  
            return curDate.getTime();  
        } catch (ParseException e) {  
            e.printStackTrace();  
        }  
        return 0;  
    }  
	
	
    /**
     * 
    * @Title: fixedDelay 
    * @Description: TODO  更偏向于计划， 计划几分钟等这样的， 不是一个固定死的时间来处理任务。 
    * @param @param executor    设定文件 
    * @return void    返回类型 
    * @throws
     */
	private static void fixedDelay(final ScheduledExecutorService executor) {
		executor.scheduleWithFixedDelay(new Runnable() {
			
			@Override
			public void run() {
 
                 System.out.println("间隔2秒调用一次....");
                 count++;
                 if(count == 10){
                	 executor.shutdown();
                 }
			}
		}, 0, 2000, TimeUnit.MILLISECONDS);
	}
 
}