init

xxl-job-admin/src/main/java/com/xxl/controller/IndexController.java

@@ -1,8 +1,10 @@
 package com.xxl.controller;
 
+import java.text.MessageFormat;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 
 import org.apache.commons.lang.StringUtils;
 import org.quartz.CronExpression;
@@ -136,4 +138,60 @@ public class IndexController {
 		return "job/help";
 	}
 	
+	private int simpleParam = 0;
+	private ThreadLocal<Integer> tlParam;
+	
+	@RequestMapping("/beat")
+	@ResponseBody
+	public String beat() {
+		if (tlParam == null) {
+			tlParam = new ThreadLocal<Integer>();
+		}
+		if (tlParam.get() == null) {
+			tlParam.set(5000);
+		}
+		simpleParam++;
+		tlParam.set(tlParam.get() + 1);
+		
+		long start = System.currentTimeMillis();
+		try {
+			TimeUnit.SECONDS.sleep(1);
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+		long end = System.currentTimeMillis();
+		return MessageFormat.format("cost:{0}, hashCode:{1}, simpleParam:{2}, tlParam:{3}", 
+				(end - start), this.hashCode(), simpleParam, tlParam.get());
+	}
+	
+	
+	public static void main(String[] args) {
+		Runnable runa = new Runnable() {
+			private int simInt = 0;
+			private ThreadLocal<Integer> tlParam = new ThreadLocal<Integer>();
+			@Override
+			public void run() {
+				while (true) {
+					try {
+						TimeUnit.SECONDS.sleep(1);
+					} catch (InterruptedException e) {
+						e.printStackTrace();
+					}
+					
+					if (tlParam.get() == null) {
+						tlParam.set(0);
+					}
+					simInt++;
+					tlParam.set(tlParam.get()+1);
+					System.out.println(Thread.currentThread().hashCode() + ":simInt:" + simInt);
+					System.out.println(Thread.currentThread().hashCode() + ":tlParam:" + tlParam.get());
+				}
+			}
+		};
+		
+		Thread t1 = new Thread(runa);
+		Thread t2 = new Thread(runa);
+		t1.start();
+		t2.start();
+	}
 }