java 多線程——一個定時調度的例子

java 多線程 目錄：

Java 多線程——基礎知識

Java 多線程 —— synchronized關鍵字

java 多線程——一個定時調度的例子

java 多線程——quartz 定時調度的例子

java 多線程—— 線程等待與喚醒

 

學習了一段時間的多線程內容，項目中有個定時調度的需求，將之前的需求重新梳理了下，寫了一個多線程調用的簡單例子，加深學習。這塊內容整理完，考慮單獨弄一個系統，用線程池來完成，另把memcached也逐步放進來，目前系統已經基本搭建完畢。

定時調度的需求如下：設定任務的開始時間，分為單次調度和循環調度，訪問指定的url。

 

package com.scheduler;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;


/**
 * 定時調度的小程序
 * @ClassName: schedulerManager
 * TODO
 * @author Xingle
 * @date 2014-8-5 下午5:24:37
 */
public class schedulerManager{
    //調度列表,格式如下
    //任務名|開始時間|間隔數量|間隔單位|程序URL地址
    //其中間隔單位用以下表示：年 year,月 month,日 day,時 hour,分 min,秒 sec
    public static ArrayList tls; 

    public static void main(String[] args) {
        tls = new ArrayList<>();
        BufferedReader ins = null;
        File f = new File("D:\\test/tasklist.txt");
        try {
            ins = new BufferedReader(new FileReader(f));
            String line = "";
            while ((line = ins.readLine()) != null) {
                //增加一個是否執行標識，0 未執行
                line = line+"|0";
                String[] task = line.split("\\|");
                tls.add(task);
            }
            ins.close();
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        
        // 開啟一個監視器
        Monitor monitor = new Monitor();
        monitor.start();

    }
}

 

 

其中，監視器如下：

package com.scheduler;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

/**
 * 監視器</br> 
 * 1. 任務列表中,若任務時間到,則新開線程執行任務</br> 
 * 2. 對於單次調度,調度后標記移除</br> 
 * 3.對於循環調度,當前調度執行完移除，任務列表增加下次循環調度的任務</br> 
 * 4. 每次遍歷休息1秒</br>
 *
 * @ClassName: Monitor
 * @author Xingle
 * @date 2014-8-5 下午5:25:01
 */
public class Monitor extends Thread {

    Monitor() {
    }

    public void run() {
        System.out.println("*** 監視器已啟動,開始遍歷監視任務列表 ***");
        while (!schedulerManager.tls.isEmpty()) {
            Date date = new Date();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String currTime = sdf.format(date);
            for (int i = 0; i < schedulerManager.tls.size(); i++) {
                String[] task = (String[]) schedulerManager.tls.get(i);
                // 任務起始時間
                String sTime = task[1];
                // 比較時間 ,開啟一個子進程去執行任務
                if (sTime.equals(currTime) && !task[5].equals("1")) {
                    execTask doTask = new execTask(task);
                    doTask.start();
                    // 已執行標示
                    task[5] = "1";
                }

                // 循環調度的任務
                if ((task[5].equals("1")) && (!task[2].equals("0"))) {
                    // 獲取循環下次調用的任務
                    String[] nexttask = getNextTask(task);
                    schedulerManager.tls.add(nexttask);
                    System.out.println("**增加循環任務：" + nexttask[0] + " 下次調用時間："
                            + nexttask[1] + " " + nexttask[4] + " 剩余："
                            + schedulerManager.tls.size());
                }
            }

            System.out.println("當前時間：" + currTime);
            for (int i = 0; i < schedulerManager.tls.size(); i++) {
                String[] task = (String[]) schedulerManager.tls.get(i);
                if (task[5].equals("1")) {
                    schedulerManager.tls.remove(i);
                    System.out.println("**減少任務：" + task[0] + " " + task[4]
                            + " 剩余：" + schedulerManager.tls.size());
                }
            }
            try {
                sleep(1000);
            } catch (Exception se) {

            }
        }

    }

    /**
     * 循環任務的下次調用任務情況
     * 
     * @param task
     * @return
     * @author xingle
     * @data 2014-8-5 下午6:34:25
     */
    private String[] getNextTask(String[] task) {
        // 下次調用時間
        String[] nextTime = new String[6];
        // 開始時間
        String start = task[1];
        // 間隔數量
        int interval = new Integer(task[2]);
        // 間隔單位
        String unit = task[3];
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        Date sdate = new Date();
        try {
            sdate = sdf.parse(start);
        } catch (ParseException e) {
            e.printStackTrace();
        }

        Calendar calendar = Calendar.getInstance();
        calendar.setTime(sdate);
        if (unit.equals("sec")) {
            calendar.add(Calendar.SECOND, interval);
        } else if (unit.equals("min")) {
            calendar.add(Calendar.MINUTE, interval);
        } else if (unit.equals("hour")) {
            calendar.add(Calendar.HOUR, interval);
        } else if (unit.equals("day")) {
            calendar.add(Calendar.DAY_OF_MONTH, interval);
        } else if (unit.equals("month")) {
            calendar.add(Calendar.MONTH, interval);
        } else if (unit.equals("year")) {
            calendar.add(Calendar.YEAR, interval);
        }
        String next = sdf.format(calendar.getTime());
        nextTime[0] = task[0];
        nextTime[1] = next;
        nextTime[2] = task[2];
        nextTime[3] = task[3];
        nextTime[4] = task[4];
        nextTime[5] = "0";
        return nextTime;
    }
}

 

監視器的執行任務的子進程：

package com.scheduler;

import java.io.IOException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

/**
 * 執行任務</br>
 * 訪問指定網址
 * @ClassName: execTask
 * 
 * @author Xingle
 * @date 2014-8-5 下午5:39:59
 */
public class execTask extends Thread{

    String[] task =null;
    
    execTask(String[] task){
        this.task = task;
    }
    public void run(){
        try {
            if(!openUrl(task[4])){
                //寫入錯誤日志文件
                System.out.println("打開錯誤: "+task.toString());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    /**
     * 打開url
     * @param inurl
     * @return
     * @author xingle
     * @throws IOException 
     * @data 2014-8-5 下午7:02:30
     */
    private boolean openUrl(String inurl) throws IOException{
        
        URL url = null;
        HttpURLConnection conn = null;
        try {
            url = new URL(inurl);
            conn = (HttpURLConnection) url.openConnection();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            System.out.println("***************** 連接失敗,程序地址 : "+inurl);
            e.printStackTrace();
            return false;
        }
        if(conn.getResponseCode()!= HttpURLConnection.HTTP_OK){
            System.out.println("****************** 調度失敗!!,程序地址 : "+inurl);
            return false;
        }
        else{
            System.out.println("********************* 已完成調度，程序地址: "+inurl);
            return true;
        }
        
    }
    
}

 

這里D:\test\tasklist.txt 中的文本如下：

task1|2014-08-06 11:42:00|5|sec|http://www.baidu.com
task2|2014-08-06 11:42:25|0|min|http://www.sina.com
task3|2014-08-06 19:00:00|3|min|http://www.cnblogs.com/xingele0917/
task4|2014-08-06 19:05:00|2|min|http://pomotodo.com/app/
task5|2014-08-06 18:09:00|1|min|http://www.w3school.com.cn/html5/

 

執行結果（截取一部分）：

*** 監視器已啟動,開始遍歷監視任務列表 ***
當前時間：2014-08-06 11:41:55
當前時間：2014-08-06 11:41:56
當前時間：2014-08-06 11:41:57
當前時間：2014-08-06 11:41:58
當前時間：2014-08-06 11:41:59
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:05 http://www.baidu.com 剩余：6
當前時間：2014-08-06 11:42:00
**減少任務：task1 http://www.baidu.com 剩余：5
********************* 已完成調度，程序地址: http://www.baidu.com
當前時間：2014-08-06 11:42:01
當前時間：2014-08-06 11:42:02
當前時間：2014-08-06 11:42:03
當前時間：2014-08-06 11:42:04
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:10 http://www.baidu.com 剩余：6
當前時間：2014-08-06 11:42:05
**減少任務：task1 http://www.baidu.com 剩余：5
********************* 已完成調度，程序地址: http://www.baidu.com
當前時間：2014-08-06 11:42:07
當前時間：2014-08-06 11:42:08
當前時間：2014-08-06 11:42:09
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:15 http://www.baidu.com 剩余：6
當前時間：2014-08-06 11:42:10
**減少任務：task1 http://www.baidu.com 剩余：5
********************* 已完成調度，程序地址: http://www.baidu.com
當前時間：2014-08-06 11:42:11
當前時間：2014-08-06 11:42:12
當前時間：2014-08-06 11:42:13
當前時間：2014-08-06 11:42:14
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:20 http://www.baidu.com 剩余：6
當前時間：2014-08-06 11:42:15
**減少任務：task1 http://www.baidu.com 剩余：5
********************* 已完成調度，程序地址: http://www.baidu.com
當前時間：2014-08-06 11:42:16
當前時間：2014-08-06 11:42:17
當前時間：2014-08-06 11:42:18
當前時間：2014-08-06 11:42:19
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:25 http://www.baidu.com 剩余：6
當前時間：2014-08-06 11:42:20
**減少任務：task1 http://www.baidu.com 剩余：5
********************* 已完成調度，程序地址: http://www.baidu.com
當前時間：2014-08-06 11:42:21
當前時間：2014-08-06 11:42:22
當前時間：2014-08-06 11:42:23
當前時間：2014-08-06 11:42:24
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:30 http://www.baidu.com 剩余：6
當前時間：2014-08-06 11:42:25
**減少任務：task2 http://www.sina.com 剩余：5
**減少任務：task1 http://www.baidu.com 剩余：4
********************* 已完成調度，程序地址: http://www.baidu.com
********************* 已完成調度，程序地址: http://www.sina.com
當前時間：2014-08-06 11:42:26
當前時間：2014-08-06 11:42:27
當前時間：2014-08-06 11:42:28
當前時間：2014-08-06 11:42:29
**增加循環任務：task1 下次調用時間：2014-08-06 11:42:35 http://www.baidu.com 剩余：5
當前時間：2014-08-06 11:42:30
**減少任務：task1 http://www.baidu.com 剩余：4
********************* 已完成調度，程序地址: http://www.baidu.com