Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for AtomicReference (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top