Often times in the server-side game logic it is necessary to use timers for recurring events that are sent to the clients (e.g. the end of a turn time, npc actions, etc).<\/p>\n
A quick solution to this problem is using the ScheduledThreadPoolExecutor<\/strong> class, provided in the JDK, which offers a convenient task executor backed by a pool of threads. SFS2X already runs its own instance of this Executor (wrapped in a class called TaskScheduler<\/em>).<\/p>\n The following snippet of Java code shows how to run a looping task using the SmartFoxServer’s own\u00a0TaskScheduler<\/strong>.<\/p>\n The scheduleAtFixedRate<\/strong> method takes four arguments:<\/p>\n The Scheduler also exposes a schedule<\/strong> method that executes a Runnable<\/em> task once after the specified amount of time. Finally the Scheduler’s thread pool can be resized on-the-fly at runtime via the resizeThreadPool()\u00a0<\/strong>method.<\/p>\n IMPORTANT<\/strong>: runtime exceptions occurring inside the run() method will stop the Task from running<\/strong>. If don’t want your Task to be interrupted by an expected error make sure to catch any Exception that might occur.<\/p>\n Finally notice how we keep track of the started task via the taskHandle<\/strong> variable and make sure to stop it when the Extension is removed, via the destroy()<\/strong> method. This is important to avoid leaking the task in memory.<\/p>\n\r\npublic class SchedulerTestExtension extends SFSExtension\r\n{\r\n private class TaskRunner implements Runnable\r\n {\r\n private int runningCycles = 0;\r\n\r\n public void run()\r\n {\r\n\t\t\ttry\r\n\t\t\t{\r\n \trunningCycles++;\r\n\t trace("Inside the running task. Cycle: " + runningCycles);\r\n\r\n\t if (runningCycles >= 10)\r\n\t {\r\n\t trace("Time to stop the task!");\r\n\t taskHandle.cancel();\r\n\t }\r\n\t\t\t}\r\n\t\t\tcatch (Exception e)\r\n\t\t\t{\r\n\t\t\t\t\/\/ Handle exceptions here\r\n\t\t\t}\r\n }\r\n }\r\n\r\n \/\/ Keeps a reference to the task execution\r\n ScheduledFuture<?> taskHandle;\r\n\r\n @Override\r\n public void init()\r\n {\r\n SmartFoxServer sfs = SmartFoxServer.getInstance();\r\n\r\n \/\/ Schedule the task to run every second, with no initial delay\r\n taskHandle = sfs.getTaskScheduler().scheduleAtFixedRate(new TaskRunner(), 0, 1, TimeUnit.SECONDS);\r\n }\r\n\r\n @Override\r\n public void destroy()\r\n {\r\n \tsuper.destroy();\r\n\r\n if (taskHandle != null)\r\n taskHandle.cancel();\r\n }\r\n\r\n}\r\n<\/pre>\n\n