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()
{
}
}