天天看點

定時啟動類[servlet],可同步或異步

import javax.servlet.*;

import javax.servlet.http.*;

import java.io.*;

import java.util.*;

import com.you9.base.WorkQueue;

public class RanksServlet extends HttpServlet

{

    private static final String CONTENT_TYPE = "text/html; charset=UTF-8";

    private boolean isSyn = true;

    //Initialize global variables

    public void init() throws ServletException

    {

        System.out.println("start RanksServlet...");

        super.init();

        RequestTask task = new RequestTask();

        task.start();

    }

    private class RequestTask extends Thread

    {

        public void run()

        {

            try

            {

                int INIT_SLEEP_INTERVAL = 10 * 1000; //首次啟動時睡眠10S後再啟動

                int EXEC_INTERVAL = 15 * 60 * 1000; //每15分鐘運作一次,更新資料

                sleep(INIT_SLEEP_INTERVAL);

                while (true)

                {

                    syncData();

                    sleep(EXEC_INTERVAL);

                }

            }

            catch (Exception ex4)

            {

                ex4.printStackTrace();

            }

        }

    }

    private void syncData()

    {

        if (isSyn)

        {

            //同步調用

            reload();

        }

        else

        {

            //異步調用

            WorkQueue.getInstance().excute(new LoadRanksData());

        }

    }

    class LoadRanksData implements Runnable

    {

        public void run()

        {

            reload();

        }

    }

    private void reload()

    {

        int ranksNum = 31;

        for (int i = 0; i <= ranksNum; i++)

        {

            Ranks ranks = RanksFactory.getInstance().getRanks(i);

            ranks.getRanks(null);

        }

    }

    //Clean up resources

    public void destroy()

    {

    }

}

繼續閱讀