import java.util.concurrent.atomic.AtomicInteger;

import org.codelibs.fess.job.JobExecutor.ShutdownListener;
import org.codelibs.fess.unit.UnitFessTestCase;

public class JobExecutorTest extends UnitFessTestCase {

    private JobExecutor jobExecutor;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        // Create a concrete implementation for testing
        jobExecutor = new TestJobExecutor();
    }

/**
 * Unit tests for {@link SmbComSeekResponse}.
 */
@ExtendWith(MockitoExtension.class)
@DisplayName("SmbComSeekResponse tests")
class SmbComSeekResponseTest {

    @Mock
    private Configuration mockConfig;

    private SmbComSeekResponse response;

    @BeforeEach
    void setUp() {
        // Setup mock configuration to avoid NPE
        when(mockConfig.getPid()).thenReturn(12345);

import org.junit.runner.Runner
import org.junit.runner.notification.RunNotifier
import org.junit.runners.JUnit4

actual class PublicSuffixTestRunner(
  klass: Class<*>,
) : Runner() {
  private val delegate = JUnit4(klass)

  override fun getDescription() = delegate.description

  override fun run(notifier: RunNotifier?) = delegate.run(notifier)

  override fun testCount() = delegate.testCount()
}

    public String toString() {
      return name;
    }
  }

  static final class Waiter {
    private final CountDownLatch started = new CountDownLatch(1);
    private final CountDownLatch canReturn = new CountDownLatch(1);
    private final CountDownLatch returned = new CountDownLatch(1);
    private Object proxy;

    @SuppressWarnings("unchecked") // proxy for a generic class

import org.codelibs.fess.opensearch.config.bsentity.BsBoostDocumentRule;

/**
 * @author FreeGen
 */
public class BoostDocumentRule extends BsBoostDocumentRule {

    private static final long serialVersionUID = 1L;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

import org.codelibs.fess.opensearch.config.bsentity.BsRelatedContent;

/**
 * @author ESFlute (using FreeGen)
 */
public class RelatedContent extends BsRelatedContent {

    private static final long serialVersionUID = 1L;

    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

      .build()

  sendRequest("https://developers.facebook.com/docs/", client)
  sendRequest("https://www.facebook.com/robots.txt", client)
  sendRequest("https://www.instagram.com/robots.txt", client)
}

private fun sendRequest(
  url: String,
  client: OkHttpClient,
) {
  val req = Request.Builder().url(url).build()

  client.newCall(req).execute().use {
    println(url)

package okhttp3.recipes.kt

import java.io.IOException
import okhttp3.Call
import okhttp3.Callback
import okhttp3.OkHttpClient
import okhttp3.Request
import okhttp3.Response

class AsynchronousGet {
  private val client = OkHttpClient()

  fun run() {
    val request =
      Request
        .Builder()
        .url("http://publicobject.com/helloworld.txt")
        .build()

    client.newCall(request).enqueue(

/**
 * Exception that wraps {@link UnsupportedOperationException}.
 *
 * @author wyukawa
 */
public class ClUnsupportedOperationException extends UnsupportedOperationException {

    private static final long serialVersionUID = -6732367317955522602L;

    /**
     * Creates a {@link ClUnsupportedOperationException}.
     */
    public ClUnsupportedOperationException() {
    }

    /**

/**
 * An artifact could not correctly being deployed.
 *
 * @since 4.0.0
 */
@Experimental
public class ArtifactDeployerException extends MavenException {

    /**
     *
     */
    @Serial
    private static final long serialVersionUID = 7421964724059077698L;

    /**
     * @param message the message of the error
     * @param e {@link Exception}
     */