- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 98 for Barker (0.16 sec)
-
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
final AtomicInteger parked = new AtomicInteger(); @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException { setCorePoolSize(parallelism + parked.incrementAndGet()); try {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
assertThat(Thread.currentThread().isInterrupted()).isFalse(); } }); // Run these together. fakePool.runAll(); // Check that this thread has been marked as interrupted again now that the thread has been // returned by SequentialExecutor. Clear the bit while checking so that the test doesn't hose // JUnit or some other test case.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/Cache.java
* * <p><b>Warning to users of Java 8+:</b> do not call any of the new <i>default methods</i> that * have been newly added to {@link ConcurrentMap}! These are marked with "Since: 1.8" in the * {@code ConcurrentMap} documentation. They will not function correctly and it is impossible for * Guava to fix them until Guava is ready to <i>require</i> Java 8 for all users. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 8.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
// we try hard to make them robust in practice. We could additionally try to add in a system // load timeout multiplier. Or we could try to use a CPU time bound instead of wall clock time // bound. But these ideas are harder to implement. We do not try to detect or handle a // user-specified -XX:+DisableExplicitGC. // // TODO(user): Consider using // java/lang/management/OperatingSystemMXBean.html#getSystemLoadAverage()
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
// Timed Get // There are a few design constraints to consider // * We want to be responsive to small timeouts, unpark() has non trivial latency overheads (I // have observed 12 micros on 64-bit linux systems to wake up a parked thread). So if the // timeout is small we shouldn't park(). This needs to be traded off with the cpu overhead of // spinning, so we use SPIN_THRESHOLD_NANOS which is what AbstractQueuedSynchronizer uses for
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
guava-tests/test/com/google/common/math/StatsTesting.java
* Stats}, {@link PairedStatsAccumulator}, and {@link PairedStats}. * * @author Pete Gillin */ class StatsTesting { // TODO(cpovirk): Convince myself that this larger error makes sense. static final double ALLOWED_ERROR = isAndroid() ? .25 : 1e-10; // Inputs and their statistics: static final double ONE_VALUE = 12.34; static final double OTHER_ONE_VALUE = -56.78;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Nov 09 22:49:56 GMT 2023 - 23.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
* amounts of computation (creating a thread, calling a few methods, etc) needed to reach a * timeout point. Similarly, a SMALL is always discriminable as larger than SHORT and smaller * than MEDIUM. And so on. These constants are set to conservative values, but even so, if * there is ever any doubt, they can all be increased in one spot to rerun tests on slower
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
* threshold has not yet been updated, so there are no atomicity requirements for this with * respect to reads. * * As a guide, all critical volatile reads and writes to the count field are marked in code * comments. */ @Weak final LocalCache<K, V> map; /** The number of live elements in this segment's region. */ volatile int count;
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 150.3K bytes - Viewed (0) -
api/maven-api-spi/src/main/java/org/apache/maven/api/spi/SpiService.java
* under the License. */ package org.apache.maven.api.spi; import org.apache.maven.api.annotations.Consumer; import org.apache.maven.api.annotations.Experimental; /** * Marker interface to indicate services that can be provided by plugins and extensions. */ @Experimental @Consumer
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Feb 28 23:32:09 GMT 2024 - 1.1K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/RepositoryMetadata.java
* * @param remoteRepository the repository */ void setRepository(ArtifactRepository remoteRepository); /** * Get the repository metadata associated with this marker. * * @return the metadata, or <code>null</code> if none loaded */ Metadata getMetadata(); /** * Set the metadata contents. * * @param metadata the metadata */
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 2.6K bytes - Viewed (0)