- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for AtomicReference (0.17 sec)
-
compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/DefaultModelResolverTest.java
.groupId("ut.simple") .artifactId("artifact") .version("(,2.0)") .build(); AtomicReference<Parent> modified = new AtomicReference<>(); assertNotNull(this.newModelResolver().resolveModel(parent, modified)); assertNotNull(modified.get()); assertEquals("1.0", modified.get().getVersion()); } @Test
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.6K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/TransformedArtifact.java
import java.nio.file.Files; import java.nio.file.Path; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.Objects; import java.util.concurrent.atomic.AtomicReference; import java.util.function.Supplier; import org.apache.maven.artifact.DefaultArtifact; import org.apache.maven.internal.transformation.TransformationFailedException;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.2K bytes - Viewed (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/DefaultModelResolver.java
} } @Override public ModelSource resolveModel(org.apache.maven.model.Parent parent) throws UnresolvableModelException { AtomicReference<org.apache.maven.api.model.Parent> resolvedParent = new AtomicReference<>(); ModelSource result = resolveModel(parent.getDelegate(), resolvedParent); if (resolvedParent.get() != null) {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 12.5K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/resolution/ModelResolver.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.model.resolution; import java.util.concurrent.atomic.AtomicReference; import org.apache.maven.api.model.Dependency; import org.apache.maven.api.model.Parent; import org.apache.maven.api.model.Repository; import org.apache.maven.model.building.ModelSource; /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
assertSame(sepLoader, sepStopwatchC.getClassLoader()); AtomicReference<Object> sepStopwatchA = new AtomicReference<Object>(sepStopwatchC.getMethod("createUnstarted").invoke(null)); AtomicReference<WeakReference<?>> sepStopwatchRef = new AtomicReference<WeakReference<?>>( (WeakReference<?>) sepFwrCons.newInstance(sepStopwatchA.get(), sepFrqA.get()));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 13.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
import java.io.InterruptedIOException import java.net.HttpURLConnection import java.time.Duration import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicReference import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.MediaType.Companion.toMediaTypeOrNull import okhttp3.TestUtil.repeat
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
new ThreadLocal<Integer>() { @Override protected Integer initialValue() { return 0; } }; final AtomicReference<Throwable> throwableFromOtherThread = new AtomicReference<>(null); final Runnable incrementTask = new Runnable() { @Override public void run() { threadLocalCount.set(threadLocalCount.get() + 1);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
*/ package okhttp3 import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicLong import java.util.concurrent.atomic.AtomicReference import okhttp3.internal.USER_AGENT import okio.ByteString /** * Exercises the web socket implementation against the * [Autobahn Testsuite](http://autobahn.ws/testsuite/). */ class AutobahnTester {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/SystemHelperTest.java
assertEquals("ok", FileUtil.readText(fileList.get(0).toFile())); } public void test_updateSystemProperties() { final SystemHelper helper = new SystemHelper(); final AtomicReference<String> appValue = new AtomicReference<>(StringUtil.EMPTY); ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { private static final long serialVersionUID = 1L; @Override
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 18.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// Since this class only needs CAS on one field, we can avoid this bug by extending AtomicReference // instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances // and DONE/INTERRUPTED - they have a common ancestor of Runnable. abstract class InterruptibleTask<T extends @Nullable Object> extends AtomicReference<@Nullable Runnable> implements Runnable { static {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 10.1K bytes - Viewed (0)