- Sort Score
- Result 10 results
- Languages All
Results 501 - 510 of 713 for threads (0.73 sec)
-
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, MILLISECONDS); Thread.sleep(20); assertFalse(taskDone); assertFalse(future.isDone()); } public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.7K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/ClingSupport.java
/** * Ctor that creates "managed" ClassWorld. This constructor is not used in "normal" circumstances. */ public ClingSupport() { this(new ClassWorld(CORE_CLASS_REALM_ID, Thread.currentThread().getContextClassLoader()), true); } /** * Ctor to be used when running in ClassWorlds Launcher. */ public ClingSupport(ClassWorld classWorld) { this(classWorld, false);Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Sat Feb 08 16:25:25 UTC 2025 - 3.6K bytes - Viewed (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
public void run() { taskDone = true; } }; ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule(task, 10, MILLISECONDS); Thread.sleep(20); assertFalse(taskDone); assertFalse(future.isDone()); } public void testNoOpScheduledExecutorShutdown() { ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt
@Throws(IOException::class) fun peekTrailers(): Headers? /** * Cancel this stream. Resources held by this stream will be cleaned up, though not synchronously. * That may happen later by the connection pool thread. */ fun cancel() /** * Carries an exchange. This is usually a connection, but it could also be a connect plan for * CONNECT tunnels. Note that CONNECT tunnels are significantly less capable than connections.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Jul 29 21:11:09 UTC 2025 - 3.3K bytes - Viewed (0) -
android/guava/src/com/google/common/reflect/TypeVisitor.java
* * <p>One {@code Type} is visited at most once. The second time the same type is visited, it's * ignored by {@link #visit}. This avoids infinite recursion caused by recursive type bounds. * * <p>This class is not thread safe. * * @author Ben Yu */ abstract class TypeVisitor { private final Set<Type> visited = new HashSet<>(); /**Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 3.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/settings/BadWordSettings.java
if (defaultWords != null) { return; } final List<String> list = new ArrayList<>(); try (BufferedReader br = new BufferedReader(new InputStreamReader( Thread.currentThread().getContextClassLoader().getResourceAsStream("suggest_settings/default-badwords.txt")))) { String line; while ((line = br.readLine()) != null) {
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Sun Nov 23 03:02:17 UTC 2025 - 5.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/FakeTicker.java
* * <p>The ticker can be configured so that the time is incremented whenever {@link #read} is called: * see {@link #setAutoIncrementStep}. * * <p>This class is thread-safe. * * @author Jige Yu * @since 10.0 */ @NullMarked @GwtCompatible public class FakeTicker extends Ticker { private final AtomicLong nanos = new AtomicLong();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 15:16:19 UTC 2025 - 4.1K bytes - Viewed (0) -
src/main/resources/fess_message_de.properties
errors.could_not_delete_logged_in_user=Sie können keinen angemeldeten Benutzer löschen. errors.unauthorized_request=Unautorisierte Anfrage. errors.failed_to_print_thread_dump=Fehler beim Drucken eines Thread-Dumps. errors.file_is_not_supported={0} wird nicht unterstützt. errors.plugin_file_is_not_found={0} wurde nicht gefunden. errors.failed_to_install_plugin=Fehler bei der Installation von {0}.Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Jul 05 02:36:47 UTC 2025 - 12.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/escape/super/com/google/common/escape/Platform.java
static char[] charBufferFromThreadLocal() { // ThreadLocal is not available to GWT, so we always reuse the same // instance. It is always safe to return the same instance because // javascript is single-threaded, and only used by blocks that doesn't // involve async callbacks. return CHAR_BUFFER; } private Platform() {}
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Jan 18 02:54:30 UTC 2025 - 1.1K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/00-bug.yml
CGO_CFLAGS="-O2 -g" CGO_CPPFLAGS="" CGO_CXXFLAGS="-O2 -g" CGO_FFLAGS="-O2 -g" CGO_LDFLAGS="-O2 -g" PKG_CONFIG="pkg-config" GOGCCFLAGS="-fPIC -arch arm64 -pthread -fno-caret-diagnostics -Qunused-arguments -fmessage-length=0 -fdebug-prefix-map=/var/folders/44/nbbyll_10jd0z8rj_qxm43740000gn/T/go-build2331607515=/tmp/go-build -gno-record-gcc-switches -fno-common" render: shell validations:Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Thu Jan 04 23:31:17 UTC 2024 - 3.3K bytes - Viewed (0)