package com.pj.apps.socket.tower;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ScheduledFuture;

import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.support.CronTrigger;


public class TaskTest {
	//需要對(duì)它進(jìn)行初始化
	private static ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); 
	//存儲(chǔ)定時(shí)任務(wù)編號(hào)及任務(wù)
	private static Map<String,ScheduledFuture<?>> map = new HashMap<>();
	//使用靜態(tài)代碼塊來(lái)初始化ThreadPoolTaskScheduler
	static {
		threadPoolTaskScheduler.initialize();
	}
	//開(kāi)啟定時(shí)任務(wù)的方法
    private static void startCron(String tNo) {
		//通過(guò)使用它的方法來(lái)對(duì)任務(wù)進(jìn)行開(kāi)啟和關(guān)閉，使用Cron表達(dá)式，表示時(shí)間間隔并重復(fù)執(zhí)行
    	ScheduledFuture<?> future = threadPoolTaskScheduler.schedule(new MyRunnable(tNo), new CronTrigger("*/5 * * * * ?"));
        map.put(tNo, future);
    } 
 
    //停關(guān)閉定時(shí)任務(wù)
    private static void closeCron(ScheduledFuture<?> future) {
       if (future != null) {
           future.cancel(true);
       }
    }

    //定時(shí)任務(wù)線程
    private static class MyRunnable implements Runnable {
    	private String tNo;
    	public MyRunnable(String tNo) {
    		this.tNo = tNo;
    	}
        @Override
        public void run() {
            System.out.println("線程編號(hào)"+tNo+"定時(shí)任務(wù)邏輯內(nèi)容...");
        }
    } 
	public static void main(String[] args) {
		startCron("9527");
		startCron("9528");
	}
}