补充内部类的例子

朱晔 · 朱晔 · commit 5b4c0d72d585 · 2020-07-06T14:35:04.000+08:00
diff --git a/src/main/java/org/geekbang/time/commonmistakes/advancedfeatures/innerclass/InnerClassApplication.java b/src/main/java/org/geekbang/time/commonmistakes/advancedfeatures/innerclass/InnerClassApplication.java
@@ -0,0 +1,27 @@
+package org.geekbang.time.commonmistakes.advancedfeatures.innerclass;
+
+public class InnerClassApplication {
+
+    private String gender = "male";
+
+    public static void main(String[] args) throws Exception {
+
+        InnerClassApplication application = new InnerClassApplication();
+        application.test();
+
+    }
+
+    private void test() {
+        MyInnerClass myInnerClass = new MyInnerClass();
+        System.out.println(myInnerClass.name);
+        myInnerClass.test();
+    }
+
+    class MyInnerClass {
+        private String name = "zhuye";
+
+        void test() {
+            System.out.println(gender);
+        }
+    }
+}
diff --git a/src/main/java/org/geekbang/time/commonmistakes/advancedfeatures/readme.md b/src/main/java/org/geekbang/time/commonmistakes/advancedfeatures/readme.md
@@ -2,3 +2,4 @@
 - 反射调用方法不是以传参决定重载：reflectionissue
 - 泛型经过类型擦除多出桥接方法的坑：genericandinheritance
 - 注解可以继承吗？：annotationinheritance
+- （补充）内部类的例子：innerclass
diff --git a/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestA.java b/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestA.java
@@ -0,0 +1,12 @@
+package org.geekbang.time.commonmistakes.springpart1.beansingletonandorder;
+
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestA {
+    @Autowired
+    @Getter
+    private TestB testB;
+}
diff --git a/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestB.java b/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestB.java
@@ -0,0 +1,12 @@
+package org.geekbang.time.commonmistakes.springpart1.beansingletonandorder;
+
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestB {
+    @Autowired
+    @Getter
+    private TestA testA;
+}
diff --git a/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestC.java b/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestC.java
@@ -0,0 +1,17 @@
+package org.geekbang.time.commonmistakes.springpart1.beansingletonandorder;
+
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Lazy;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestC {
+    @Getter
+    private TestD testD;
+
+    @Autowired
+    public TestC(@Lazy TestD testD) {
+        this.testD = testD;
+    }
+}
diff --git a/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestD.java b/src/main/java/org/geekbang/time/commonmistakes/springpart1/beansingletonandorder/TestD.java
@@ -0,0 +1,16 @@
+package org.geekbang.time.commonmistakes.springpart1.beansingletonandorder;
+
+import lombok.Getter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TestD {
+    @Getter
+    private TestC testC;
+
+    @Autowired
+    public TestD(TestC testC) {
+        this.testC = testC;
+    }
+}
diff --git a/src/main/java/org/geekbang/time/commonmistakes/threadpool/threadpooloom/ThreadPoolOOMController.java b/src/main/java/org/geekbang/time/commonmistakes/threadpool/threadpooloom/ThreadPoolOOMController.java
@@ -109,10 +109,11 @@ public int right() throws InterruptedException {
 
     @GetMapping("better")
     public int better() throws InterruptedException {
-        AtomicInteger atomicInteger = new AtomicInteger();
+        //这里开始是激进线程池的实现
         BlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(10) {
             @Override
             public boolean offer(Runnable e) {
+                //先返回false，造成队列满的假象，让线程池优先扩容
                 return false;
             }
         };
@@ -122,16 +123,23 @@ public boolean offer(Runnable e) {
                 5, TimeUnit.SECONDS,
                 queue, new ThreadFactoryBuilder().setNameFormat("demo-threadpool-%d").get(), (r, executor) -> {
             try {
-                //executor.getQueue().put(r);
+                //等出现拒绝后再加入队列
+                //如果希望队列满了阻塞线程而不是抛出异常，那么可以注释掉下面三行代码，修改为executor.getQueue().put(r);
                 if (!executor.getQueue().offer(r, 0, TimeUnit.SECONDS)) {
                     throw new RejectedExecutionException("ThreadPool queue full, failed to offer " + r.toString());
                 }
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
             }
         });
+        //激进线程池实现结束
 
         printStats(threadPool);
+        //每秒提交一个任务，每个任务耗时10秒执行完成，一共提交20个任务
+
+        //任务编号计数器
+        AtomicInteger atomicInteger = new AtomicInteger();
+
         IntStream.rangeClosed(1, 20).forEach(i -> {
             try {
                 TimeUnit.SECONDS.sleep(1);
