ramsayleung / blog Goto Github PK

     1  public void Test(){
     2      private static Integer index = 0;
     3      Lock lock = new ReentrantLock(true);
     4      @Test
     5      public void testLock(){
     6              Thread threadA = work(() -> System.out.println("A"));
     7              Thread threadB = work(() -> System.out.println("B"));
     8              Thread threadC = work(() -> System.out.println("C"));
     9              threadA.setName("threadA");
    10              threadA.start();
    11              threadB.setName("threadB");
    12              threadB.start();
    13              threadC.setName("threadC");
    14              threadC.start();
    15              System.out.println();
    16      }
    17
    18      private Thread work(Runnable function) {
    19              return new Thread(() -> {
    20                  while (index.intValue() < 3) {
    21                  lock.lock();
    22                  if (index >= 3) {
    23                      // lock.unlock();
    24                      continue;
    25                  }
    26                  if (condition.test(index.intValue())) {
    27                      function.run();
    28                      index++;
    29                  }
    30                  lock.unlock();
    31                  }
    32              });
    33      }
    34  }