瀏覽代碼

Merge branch 'dev' of http://www.ekexiu.com:3000/jiapeng/portal-web.git into dev

jiapeng 8 年之前
父節點
當前提交
481bc644af
共有 1 個文件被更改,包括 3 次插入2 次删除
  1. 3 2
      src/main/java/com/ekexiu/portal/job/TaskJob.java

+ 3 - 2
src/main/java/com/ekexiu/portal/job/TaskJob.java

@ -4,16 +4,17 @@ import java.text.DateFormat;
4 4
import java.text.ParseException;
5 5
import java.text.SimpleDateFormat;
6 6
import java.util.Date;
7
import java.util.concurrent.Executors;
8 7
import java.util.concurrent.ScheduledExecutorService;
9 8
import java.util.concurrent.TimeUnit;
10 9

11 10
import org.jfw.apt.annotation.Bean;
12 11
import org.jfw.util.bean.AfterBeanFactory;
13 12
import org.jfw.util.bean.BeanFactory;
13
import org.jfw.util.context.JfwAppContext;
14 14

15 15
@Bean
16 16
public class TaskJob implements AfterBeanFactory {
17
	private ScheduledExecutorService service;
17 18
	
18 19
	@Override
19 20
	public void handle(BeanFactory bf) throws Throwable {
@ -26,7 +27,7 @@ public class TaskJob implements AfterBeanFactory {
26 27
		long taskTime = task - System.currentTimeMillis();
27 28
		taskTime = taskTime > 0 ? taskTime : delayTime + taskTime;
28 29
		
29
        ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
30
        this.service = JfwAppContext.getScheduledExecutorService();
30 31
        // 第二个参数为首次执行的延时时间,第三个参数为定时执行的间隔时间  
31 32
		service.scheduleAtFixedRate(tje, taskTime, delayTime, TimeUnit.MILLISECONDS);
32 33
//		service.scheduleAtFixedRate(ultje, taskTime, delayTime, TimeUnit.MILLISECONDS);