- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of about 10,000 for finalA (0.24 sec)
-
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
final CrawlerWebServer server1 = new CrawlerWebServer(7070); server1.start(); final CrawlerWebServer server2 = new CrawlerWebServer(7071); server2.start(); final String url1 = "http://localhost:7070/"; final String url2 = "http://localhost:7071/"; try { final int maxCount = 10; final int numOfThread = 10;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 18K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy
import java.util.concurrent.locks.ReentrantLock class TestManagedExecutor extends AbstractExecutorService implements ManagedExecutor { private final Lock lock = new ReentrantLock() private final Condition condition = lock.newCondition() private int count private final TestExecutor executor; TestManagedExecutor(TestExecutor executor) { this.executor = executor } void execute(Runnable command) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
// ---------------------------------------------------------------- class Interruptenator extends Thread { final AtomicBoolean shutdown; Interruptenator(final Thread interruptee) { this(interruptee, new AtomicBoolean(false)); } Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) { super( new Runnable() { @Override public void run() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 7.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testCancel_interrupted() throws Exception { final AtomicBoolean interruptedExceptionThrown = new AtomicBoolean(); final CountDownLatch enterLatch = new CountDownLatch(1); final CountDownLatch exitLatch = new CountDownLatch(1); final TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create( new Callable<Integer>() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
} class TestThread extends Thread { private static final Logger LOG = LoggerFactory.getLogger(TestThread.class) private final ConcurrentTestUtil owner private final Runnable action private final Lock lock private final Condition stateChanged private boolean complete TestThread(ConcurrentTestUtil owner, Lock lock, Runnable action) { this.owner = owner this.action = action
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
// ---------------------------------------------------------------- class Interruptenator extends Thread { final AtomicBoolean shutdown; Interruptenator(final Thread interruptee) { this(interruptee, new AtomicBoolean(false)); } Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) { super( new Runnable() { @Override public void run() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 7.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
} @J2ktIncompatible @GwtIncompatible // blocking wait public void testCancel_interrupted() throws Exception { final AtomicBoolean interruptedExceptionThrown = new AtomicBoolean(); final CountDownLatch enterLatch = new CountDownLatch(1); final CountDownLatch exitLatch = new CountDownLatch(1); final TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create( new Callable<Integer>() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 7.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
private final byte[] content; private final Lock lock; private final Duration timeout; private final Condition condition; private final WaitPrecondition precondition; private boolean requestStarted; private boolean released; private final Clock clock = Time.clock(); private long mostRecentEvent; private AssertionError failure;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java
* closed, all threads blocked reading from the stream will receive an end-of-stream. */ public class DisconnectableInputStream extends BulkReadInputStream { private final Lock lock = new ReentrantLock(); private final Condition condition = lock.newCondition(); private final byte[] buffer; private int readPos; private int writePos; private boolean closed; private boolean inputFinished; /*
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:46 UTC 2021 - 6.5K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/processors/TestMainAction.java
public class TestMainAction implements Runnable { private final Runnable detector; private final TestClassProcessor processor; private final TestResultProcessor resultProcessor; private final WorkerLeaseService workerLeaseService; private final Clock clock; private final Object rootTestSuiteId; private final String displayName;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3.2K bytes - Viewed (0)