runnable: Runnable,
    ) {
      executor.execute(runnable)
    }

    fun shutdown() {
      executor.shutdown()
    }
  }

  companion object {
    val logger: Logger = Logger.getLogger(TaskRunner::class.java.name)

    @JvmField
    val INSTANCE = TaskRunner(RealBackend(threadFactory("$okHttpName TaskRunner", daemon = true)))
  }

 *
 *  * By yielding in [TaskRunner.Backend.coordinatorWait].
 *  * By yielding in [BlockingQueue.poll].
 *  * By completing.
 */
class TaskFaker : Closeable {
  val logger = Logger.getLogger("TaskFaker." + instance++)

  /** Though this executor service may hold many threads, they are not executed concurrently. */
  private val tasksExecutor = Executors.newCachedThreadPool(threadFactory("TaskFaker"))

  /**

 * collected, and this class can detect when the main class loader has been garbage collected and
 * stop itself.
 */
public class Finalizer implements Runnable {

  private static final Logger logger = Logger.getLogger(Finalizer.class.getName());

  /**
   * Starts the Finalizer thread. FinalizableReferenceQueue calls this method reflectively.
   *
   * @param finalizableReferenceClass FinalizableReference.class.

 *
 * @since 3.0
 */
@Named
@Singleton
public class MojoDescriptorCreator {
    private final Logger logger = LoggerFactory.getLogger(getClass());
    private final PluginVersionResolver pluginVersionResolver;
    private final BuildPluginManager pluginManager;
    private final PluginPrefixResolver pluginPrefixResolver;

    /**
     * Default constructor.
     */
    public ApiAdminBadwordAction() {
        super();
    }

    private static final Logger logger = LogManager.getLogger(ApiAdminBadwordAction.class);

    @Resource
    private BadWordService badWordService;

    /** Helper for managing search suggestions and bad words */
    @Resource
    protected SuggestHelper suggestHelper;

import com.google.cloud.storage.StorageOptions;

/**
 * Google Cloud Storage client implementation.
 */
public class GcsStorageClient implements StorageClient {

    private static final Logger logger = LogManager.getLogger(GcsStorageClient.class);

    private final Storage storage;
    private final String bucket;

    /**
     * Creates a new GcsStorageClient instance.
     *
     * @param projectId the GCS project ID

 * used in various SMB2/SMB3 dialect versions.
 *
 * @author mbechler
 */
public class Smb2SigningDigest implements SMBSigningDigest, AutoCloseable {

    private static final Logger log = LoggerFactory.getLogger(Smb2SigningDigest.class);

    /**
     *
     */
    private static final int SIGNATURE_OFFSET = 48;
    private static final int SIGNATURE_LENGTH = 16;
    private final Mac digest;

import jcifs.internal.CommonServerMessageBlock;

/**
 * Handles failover and recovery for multi-channel connections
 */
public class ChannelFailover {

    private static final Logger log = LoggerFactory.getLogger(ChannelFailover.class);

    private final ChannelManager manager;
    private final ExecutorService executor;
    private final ConcurrentMap<String, FailoverState> failoverStates;

    /**

 * API action for admin web configuration management.
 *
 */
public class ApiAdminWebconfigAction extends FessApiAdminAction {

    /** The logger for this class. */
    private static final Logger logger = LogManager.getLogger(ApiAdminWebconfigAction.class);

    // ===================================================================================
    //                                                                         Constructor

/**
 * API action for admin key match management.
 *
 */
public class ApiAdminKeymatchAction extends FessApiAdminAction {

    /** The logger for this class. */
    private static final Logger logger = LogManager.getLogger(ApiAdminKeymatchAction.class);

    // ===================================================================================
    //                                                                         Constructor