- Sort Score
- Num 10 results
- Language All
Results 201 - 210 of 322 for subdir (0.05 seconds)
-
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isDone()); assertFalse(future.isCancelled()); ExecutorService executor = newSingleThreadExecutor(); try { Future<Boolean> getResult = executor.submit(() -> future.get()); // Release the future value. latch.countDown(); assertTrue(getResult.get(10, SECONDS)); } finally { executor.shutdownNow(); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 6.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java
// When generating nonces concurrently ExecutorService executor = Executors.newFixedThreadPool(threadCount); for (int t = 0; t < threadCount; t++) { executor.submit(() -> { try { for (int i = 0; i < noncesPerThread; i++) { byte[] nonce = context.generateNonce(); String nonceStr = Arrays.toString(nonce);Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 44.1K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ElasticsearchJavaBasePlugin.java
* -serial because we don't use java serialization. */ // don't even think about passing args with -J-xxx, oracle will ask you to submit a bug report :) // fail on all javac warnings. // TODO Discuss moving compileOptions.getCompilerArgs() to use provider api with Gradle team.
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Mon Sep 27 16:04:42 GMT 2021 - 8K bytes - Click Count (0) -
src/main/webapp/WEB-INF/view/admin/searchlist/admin_searchlist_edit.jsp
<la:message key="labels.crud_button_back"/> </la:link> <button type="submit" class="btn btn-success" name="create" value="<la:message key="labels.crud_button_create" />"> <i class="fa fa-plus" aria-hidden="true"></i>
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:38:39 GMT 2026 - 28.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return new NoOpScheduledExecutorService(); } /** * Creates a scheduled executor service that runs each task in the thread that invokes {@code * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
src/main/webapp/js/suggestor.js
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 11:04:08 GMT 2025 - 13.3K bytes - Click Count (0) -
.github/DISCUSSION_TEMPLATE/questions.yml
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Aug 03 15:59:41 GMT 2023 - 5.8K bytes - Click Count (0) -
docs/bigdata/README.md
``` cd /usr/hdp/current/spark2-client su spark ``` - Run the Apache Spark Pi job in yarn-client mode, using code from **org.apache.spark**: ``` ./bin/spark-submit --class org.apache.spark.examples.SparkPi \ --master yarn-client \ --num-executors 1 \ --driver-memory 512m \ --executor-memory 512m \ --executor-cores 1 \Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 14.7K bytes - Click Count (0) -
cmd/iam-object-store.go
policyDBSTSUsersListKey = "policydb/sts-users/" policyDBGroupsListKey = "policydb/groups/" ) func findSecondIndex(s string, substr string) int { first := strings.Index(s, substr) if first == -1 { return -1 } second := strings.Index(s[first+1:], substr) if second == -1 { return -1 } return first + second + 1 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 26.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
@Override protected void setUp() { ExecutorService executor = newSingleThreadExecutor(); tearDownStack.addTearDown(executor::shutdownNow); sleeper = new SleepingRunnable(1000); delayedFuture = executor.submit(sleeper, true); tearDownStack.addTearDown(() -> Thread.interrupted()); } @Override protected void tearDown() { tearDownStack.runTearDown(); } /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0)