update

Author: kimmking

02nio/nio01/src/main/java/java0/nio01/netty/NettyHttpServer.java

@@ -22,14 +22,14 @@ public static void main(String[] args) throws InterruptedException {
         try {
             ServerBootstrap b = new ServerBootstrap();
             b.option(ChannelOption.SO_BACKLOG, 128)
-                    .option(ChannelOption.TCP_NODELAY, true)
-                    .option(ChannelOption.SO_KEEPALIVE, true)
-                    .option(ChannelOption.SO_REUSEADDR, true)
-                    .option(ChannelOption.SO_RCVBUF, 32 * 1024)
-                    .option(ChannelOption.SO_SNDBUF, 32 * 1024)
-                    .option(EpollChannelOption.SO_REUSEPORT, true)
+                    .childOption(ChannelOption.TCP_NODELAY, true)
                     .childOption(ChannelOption.SO_KEEPALIVE, true)
-                    .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
+                    .childOption(ChannelOption.SO_REUSEADDR, true)
+                    .childOption(ChannelOption.SO_RCVBUF, 32 * 1024)
+                    .childOption(ChannelOption.SO_SNDBUF, 32 * 1024)
+                    .childOption(EpollChannelOption.SO_REUSEPORT, true)
+                    .childOption(ChannelOption.SO_KEEPALIVE, true)
+                    .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
 
             b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
                     .handler(new LoggingHandler(LogLevel.INFO))

03concurrency/0301/src/main/java/java0/conc0301/ThreadCount.java

@@ -0,0 +1,11 @@
+package java0.conc0301;
+
+public class ThreadCount {
+    public static void main(String[] args) throws InterruptedException {
+        //System.out.println("system："+Thread.currentThread().getThreadGroup().getParent());
+        Thread.currentThread().getThreadGroup().getParent().list();
+
+//        System.out.println("main："+Thread.currentThread().getThreadGroup());
+//        Thread.currentThread().getThreadGroup().list();
+    }
+}

03concurrency/0301/src/main/java/java0/conc0301/op/Join.java

@@ -6,14 +6,16 @@ public static void main(String[] args) {
         Object oo = new Object();
 
         MyThread thread1 = new MyThread("thread1 -- ");
-        thread1.setOo(thread1);
+        //oo = thread1;
+        thread1.setOo(oo);
         thread1.start();
 
-        synchronized (thread1) {  // 这里用oo或thread1/this
+        synchronized (oo) {  // 这里用oo或thread1/this
             for (int i = 0; i < 100; i++) {
                 if (i == 20) {
                     try {
-                        thread1.join();
+                        oo.wait(0);
+                        //thread1.join();
                     } catch (InterruptedException e) {
                         e.printStackTrace();
                     }
@@ -40,7 +42,7 @@ public MyThread(String name) {
 
     @Override
     public void run() {
-        synchronized (this) { // 这里用oo或this，效果不同
+        synchronized (oo) { // 这里用oo或this，效果不同
             for (int i = 0; i < 100; i++) {
                 System.out.println(name + i);
             }