Selaa lähdekoodia

Merge branch 'master' of https://github.com/xuxueli/xxl-job.git

xueli.xue 9 vuotta sitten
vanhempi
commit
ff0b4533bc

+ 24 - 0
xxl-job-admin/src/main/java/com/xxl/job/service/job/impl/DemoConcurrentJobBean.java Näytä tiedosto

@@ -0,0 +1,24 @@
1
+package com.xxl.job.service.job.impl;
2
+
3
+import java.util.concurrent.TimeUnit;
4
+
5
+import org.quartz.DisallowConcurrentExecution;
6
+
7
+import com.xxl.job.service.job.LocalNomalJobBean;
8
+
9
+@DisallowConcurrentExecution	// 串行;线程数要多配置几个,否则不生效;
10
+public class DemoConcurrentJobBean extends LocalNomalJobBean {
11
+
12
+	@Override
13
+	public Object handle(String... param) {
14
+		
15
+		try {
16
+			TimeUnit.SECONDS.sleep(10);
17
+		} catch (InterruptedException e) {
18
+			e.printStackTrace();
19
+		}
20
+		
21
+		return false;
22
+	}
23
+
24
+}

+ 26 - 0
xxl-job-admin/src/main/java/com/xxl/job/service/job/impl/DemoNomalJobBean.java Näytä tiedosto

@@ -0,0 +1,26 @@
1
+package com.xxl.job.service.job.impl;
2
+
3
+import java.util.concurrent.TimeUnit;
4
+
5
+import org.slf4j.Logger;
6
+import org.slf4j.LoggerFactory;
7
+
8
+import com.xxl.job.service.job.LocalNomalJobBean;
9
+
10
+public class DemoNomalJobBean extends LocalNomalJobBean {
11
+	private static Logger Logger = LoggerFactory.getLogger(DemoNomalJobBean.class);
12
+	
13
+	@Override
14
+	public Object handle(String... param) {
15
+		Logger.info("DemoNomalJobBean run :" + param);
16
+		
17
+		try {
18
+			TimeUnit.SECONDS.sleep(10);
19
+		} catch (InterruptedException e) {
20
+			e.printStackTrace();
21
+		}
22
+		
23
+		return false;
24
+	}
25
+
26
+}