* sent. Unfortunately calling disconnect() doesn't always
                         * actually shutdown the connection before other threads
                         * have committed themselves (e.g. InterruptTest example).
                         */
                        try {
                            trans.disconnect(true);

    assertFalse(completed);
    thread.start();
    thread.join();
    assertTrue(completed);

    // Creating a new thread from the same ThreadFactory will have the same
    // pool ID but a thread ID of 2.
    Thread thread2 = threadFactory.newThread(monitoredRunnable);
    checkThreadPoolName(thread2, 2);
    assertEquals(

    /** The key of the message: Name */
    public static final String LABELS_NAME = "{labels.name}";

    /** The key of the message: Number of Threads */
    public static final String LABELS_NUM_OF_THREAD = "{labels.numOfThread}";

    /** The key of the message: Duplicate Host Name */
    public static final String LABELS_DUPLICATE_HOST_NAME = "{labels.duplicateHostName}";

                        successCount.incrementAndGet();
                    }
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                } finally {
                    endLatch.countDown();
                }
            }
        });

        Thread thread2 = new Thread(new Runnable() {

     * is not observed after a sufficient number of reads, try cleaning up from the read thread.
     */
    void postReadCleanup() {
      if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
        cleanUp();
      }
    }

    /**
     * Performs routine cleanup prior to executing a write. This should be called every time a write
     * thread acquires the segment lock, immediately after acquiring the lock.

    assertFalse(completed);
    thread.start();
    thread.join();
    assertTrue(completed);

    // Creating a new thread from the same ThreadFactory will have the same
    // pool ID but a thread ID of 2.
    Thread thread2 = threadFactory.newThread(monitoredRunnable);
    checkThreadPoolName(thread2, 2);
    assertEquals(

          @Override
          public void run() {
            list.execute();
          }
        };
    Thread thread1 = new Thread(execute);
    Thread thread2 = new Thread(execute);
    thread1.start();
    thread2.start();
    assertEquals(0, runCalled.get());
    okayToRun.countDown();
    thread1.join();
    thread2.join();
    assertEquals(1, runCalled.get());
  }

  public void testAddAfterRun() throws Exception {

          @Override
          public void run() {
            list.execute();
          }
        };
    Thread thread1 = new Thread(execute);
    Thread thread2 = new Thread(execute);
    thread1.start();
    thread2.start();
    assertEquals(0, runCalled.get());
    okayToRun.countDown();
    thread1.join();
    thread2.join();
    assertEquals(1, runCalled.get());
  }

  public void testAddAfterRun() throws Exception {

            // When - simulate concurrent requests
            Thread thread1 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, false));
            Thread thread2 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, true));

            thread1.start();
            thread2.start();
            thread1.join();
            thread2.join();

            // Then

            // When - simulate concurrent access
            Thread thread1 = new Thread(() -> {
                try {
                    response.readBytesWireFormat(buffer1, 0);
                } catch (SMBProtocolDecodingException e) {
                    fail("Thread 1 failed: " + e.getMessage());
                }
            });

            Thread thread2 = new Thread(() -> {