}

    @Override
    public void remove() {
      valueIterator.remove();
      /*
       * requireNonNull is safe because we've already initialized `collection`. If we hadn't, then
       * valueIterator.remove() would have failed.
       */
      if (requireNonNull(collection).isEmpty()) {
        keyIterator.remove();
      }
      totalSize--;

    @SuppressWarnings("unchecked")
    @Nullable V[][] tmpArray = (@Nullable V[][]) new Object[rowList.size()][columnList.size()];
    array = tmpArray;
    // Necessary because in GWT the arrays are initialized with "undefined" instead of null.
    eraseAll();
  }

  private ArrayTable(Table<R, C, ? extends @Nullable V> table) {
    this(table.rowKeySet(), table.columnKeySet());
    putAll(table);
  }

     * @return a new ThreadPoolExecutor configured for this callback
     */
    protected ExecutorService newFixedThreadPool(final int nThreads) {
        if (logger.isDebugEnabled()) {
            logger.debug("Initialized executor thread pool: size={}", nThreads);
        }
        return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(nThreads),

   *
   * <p>This class would certainly be simpler and easier to reason about if it were built with
   * ThreadLocal; however, ThreadLocal is not well optimized for the case where the ThreadLocal is
   * non-static, and is initialized/removed frequently - this causes churn in the Thread specific
   * hashmaps. Using a static ThreadLocal to avoid that overhead would mean that different

    if (!serverCapabilities.contains(SMB2_GLOBAL_CAP_MULTI_CHANNEL)) {
        log.debug("Server does not support multi-channel");
        return;
    }
    
    multiChannelSupported = true;
    
    // Initialize channel manager
    channelManager = new ChannelManager(context, this);
    channelManager.initializeMultiChannel();
}

public SmbTransport selectTransport(SMBMessage message) {

                    }
                    return list.toArray(new Artifact[list.size()]);
                }
            });

    /**
     * Default constructor for PluginHelper.
     * Initializes the plugin helper with default settings.
     */
    public PluginHelper() {
        // Default constructor
    }

    /**

    protected int splitHashSize = 10;

    /**
     * Default constructor for ThumbnailManager.
     */
    public ThumbnailManager() {
        // Default constructor
    }

    /**
     * Initializes the thumbnail manager after construction.
     * Sets up base directory and starts background processing.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {

       * fact we are holding it because it is the same as this.lock, which we know we are holding,
       * thanks to @GuardedBy above. (cancellationDelegate.lock is initialized to this.lock in the
       * call to `new SupplantableFuture` below.)
       */
      @SuppressWarnings("GuardedBy")
      private Cancellable initializeOrUpdateCancellationDelegate(Schedule schedule) {

    /**
     * Creates a new TikaExtractor instance.
     */
    public TikaExtractor() {
        super();
    }

    /**
     * Initializes this component.
     */
    @PostConstruct
    public void init() {
        if (tikaConfig == null && crawlerContainer != null) {
            try {

          return 0
        }
      }

    /**
     * Holds interned instances. This needs to be above the init() calls below so that it's
     * initialized by the time those parts of `<clinit>()` run. Guarded by CipherSuite.class.
     */
    private val INSTANCES = mutableMapOf<String, CipherSuite>()

    // Last updated 2016-07-03 using cipher suites from Android 24 and Java 9.