JavaCourse00
diff --git a/‎02nio/nio02/src/main/java/io/github/kimmking/gateway/router/HttpEndpointRouter.java‎
Lines changed: 8 additions & 0 deletions b/‎02nio/nio02/src/main/java/io/github/kimmking/gateway/router/HttpEndpointRouter.java‎
Lines changed: 8 additions & 0 deletions
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/DaemonThread.java‎
Lines changed: 1 addition & 1 deletion b/‎03concurrency/0301/src/main/java/java0/conc0301/DaemonThread.java‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/Runner2.java‎
Lines changed: 3 additions & 1 deletion b/‎03concurrency/0301/src/main/java/java0/conc0301/Runner2.java‎
Lines changed: 3 additions & 1 deletion
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/RunnerMain.java‎
Lines changed: 9 additions & 5 deletions b/‎03concurrency/0301/src/main/java/java0/conc0301/RunnerMain.java‎
Lines changed: 9 additions & 5 deletions
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/ThreadB.java‎
Lines changed: 1 addition & 1 deletion b/‎03concurrency/0301/src/main/java/java0/conc0301/ThreadB.java‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/ThreadMain.java‎
Lines changed: 1 addition & 1 deletion b/‎03concurrency/0301/src/main/java/java0/conc0301/ThreadMain.java‎
Lines changed: 1 addition & 1 deletion
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/op/Join.java‎
Lines changed: 2 additions & 2 deletions b/‎03concurrency/0301/src/main/java/java0/conc0301/op/Join.java‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/op/WaitAndNotify.java‎
Lines changed: 9 additions & 9 deletions b/‎03concurrency/0301/src/main/java/java0/conc0301/op/WaitAndNotify.java‎
Lines changed: 9 additions & 9 deletions
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/sync/Counter.java‎
Lines changed: 9 additions & 6 deletions b/‎03concurrency/0301/src/main/java/java0/conc0301/sync/Counter.java‎
Lines changed: 9 additions & 6 deletions
diff --git a/‎03concurrency/0301/src/main/java/java0/conc0301/sync/Cref.java‎
Lines changed: 8 additions & 0 deletions b/‎03concurrency/0301/src/main/java/java0/conc0301/sync/Cref.java‎
Lines changed: 8 additions & 0 deletions
@@ -6,4 +6,12 @@ public interface HttpEndpointRouter {
 
     String route(List<String> endpoints);
 
+    // Load Balance
+    // Random
+    // RoundRibbon 
+    // Weight
+    // - server01,20
+    // - server02,30
+    // - server03,50
+    
 }
@@ -17,7 +17,7 @@ public void run() {
         };
         Thread thread = new Thread(task);
         thread.setName("test-thread-1");
-        thread.setDaemon(true);
+        thread.setDaemon(false);
         thread.start();
     }
 
 
@@ -11,11 +11,13 @@ public void run() {
         boolean result = Thread.currentThread().isInterrupted();
 
         boolean result1 = Thread.interrupted(); // 重置状态
-
+        
         boolean result3 = Thread.currentThread().isInterrupted();
 
         System.out.println("Runner2.run result ===>" + result);
         System.out.println("Runner2.run result1 ===>" + result1);
         System.out.println("Runner2.run result3 ===>" + result3);
+        
+        
     }
 }
@@ -1,9 +1,11 @@
 
 package java0.conc0301;
 
+import java.io.IOException;
+
 public class RunnerMain {
 
-    public static void main(String[] args) {
+    public static void main(String[] args) throws IOException {
 
         Runner1 runner1 = new Runner1();
         Thread thread1 = new Thread(runner1);
@@ -14,12 +16,14 @@ public static void main(String[] args) {
         thread1.start();
         thread2.start();
 
-        thread2.interrupt();
+        thread2.interrupt();  // i = true
 
         System.out.println(Thread.activeCount());
 
-//        Thread.currentThread().getThreadGroup().list();
-//        System.out.println(Thread.currentThread().getThreadGroup().getParent().activeGroupCount());
-//        Thread.currentThread().getThreadGroup().getParent().list();
+        Thread.currentThread().getThreadGroup().list();
+        System.out.println(Thread.currentThread().getThreadGroup().getParent().activeGroupCount());
+        Thread.currentThread().getThreadGroup().getParent().list();
+    
+        
     }
 }
@@ -15,7 +15,7 @@ public void run() {
         String currentThreadName = currentThread.getName();
 
         System.out.println("这是线程的名称：" + currentThreadName);
-        System.out.println("返回当前线程" + currentThreadName + "的线程组中活动线程的数量:" + Thread.activeCount());
+        System.out.println("返回当前线程" + currentThreadName + "的线程组中活动线程的数量:" + Thread.currentThread().getThreadGroup().activeCount());
         System.out.println("返回该线程" + currentThreadName + "的标识符:" + currentThread.getId());
         System.out.println("返回该线程" + currentThreadName + "的优先级:" + currentThread.getPriority());
         System.out.println("返回该线程" + currentThreadName + "的状态:" + currentThread.getState());
 
@@ -15,7 +15,7 @@ public static void main(String[] args) {
         new Thread(threadB).start();
         System.out.println("这是主线程：");
 
-        ThreadC threadC = new ThreadC();
+        ThreadC threadC = new ThreadC(); 
         FutureTask<String> futureTask = new FutureTask<>(threadC);
         new Thread(futureTask).start();
         System.out.println("这是主线程:begin!");
 
@@ -9,7 +9,7 @@ public static void main(String[] args) {
         thread1.setOo(oo);
         thread1.start();
 
-        synchronized (oo) {
+        synchronized (thread1) {
             for (int i = 0; i < 100; i++) {
                 if (i == 20) {
                     try {
@@ -40,7 +40,7 @@ public MyThread(String name) {
 
     @Override
     public void run() {
-        synchronized (oo) {
+        synchronized (this) {
             for (int i = 0; i < 100; i++) {
                 System.out.println(name + i);
             }
 
@@ -19,17 +19,17 @@ public static void main(String[] args) {
                 e.printStackTrace();
             }
         }, "t2");
-        Thread t3 = new Thread(() -> {
-            try {
-                methodClass.customer();
-            } catch (InterruptedException e) {
-                // TODO Auto-generated catch block
-                e.printStackTrace();
-            }
-        }, "t3");
+//        Thread t3 = new Thread(() -> {
+//            try {
+//                methodClass.customer();
+//            } catch (InterruptedException e) {
+//                // TODO Auto-generated catch block
+//                e.printStackTrace();
+//            }
+//        }, "t3");
         t1.start();
         t2.start();
-        t3.start();
+        //t3.start();
 
     }
 }
 
@@ -1,17 +1,21 @@
 package java0.conc0301.sync;
 
 public class Counter {
-    private int sum = 0;
+    
+    public final static int A=10;
+    
+    public static int B=10;
+    
+    private volatile int sum = 0;
     public synchronized void incr() {
-    	int a = sum;
-        sum = a + 1;
+        sum=sum+1;
     }
     public int getSum() {
         return sum;
     }
 
     public static void main(String[] args) throws InterruptedException {
-        int loop = 10000;
+        int loop = 100000;
 
         // test single thread
          Counter counter = new Counter();
@@ -40,8 +44,7 @@ public static void main(String[] args) throws InterruptedException {
         });
         t1.start();
         t2.start();
-//        t3.start();
-        Thread.sleep(300);
+        Thread.sleep(1000);
 //        while (Thread.activeCount()>2){//当前线程的线程组中的数量>2
 //            Thread.yield();
 //        }
 
@@ -0,0 +1,8 @@
+package java0.conc0301.sync;
+
+public class Cref {
+    public static void main(String[] args) {
+        int x = 10;
+        int y = Counter.B;
+    }
+}
Original file line number	Diff line number	Diff line change
`@@ -17,7 +17,7 @@ public void run() {`
`17`	`17`	`};`
`18`	`18`	`Thread thread = new Thread(task);`
`19`	`19`	`thread.setName("test-thread-1");`
`20`		`- thread.setDaemon(true);`
	`20`	`+ thread.setDaemon(false);`
`21`	`21`	`thread.start();`
`22`	`22`	`}`
`23`	`23`
Original file line number	Diff line number	Diff line change
`@@ -11,11 +11,13 @@ public void run() {`
`11`	`11`	`boolean result = Thread.currentThread().isInterrupted();`
`12`	`12`
`13`	`13`	`boolean result1 = Thread.interrupted(); // 重置状态`
`14`		`-`
	`14`	`+`
`15`	`15`	`boolean result3 = Thread.currentThread().isInterrupted();`
`16`	`16`
`17`	`17`	`System.out.println("Runner2.run result ===>" + result);`
`18`	`18`	`System.out.println("Runner2.run result1 ===>" + result1);`
`19`	`19`	`System.out.println("Runner2.run result3 ===>" + result3);`
	`20`	`+`
	`21`	`+`
`20`	`22`	`}`
`21`	`23`	`}`