Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 335 for atomics (0.04 sec)

  1. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

    import java.lang.ref.WeakReference;
    import java.lang.reflect.Constructor;
    import java.lang.reflect.Field;
    import java.net.MalformedURLException;
    import java.net.URL;
    import java.net.URLClassLoader;
    import java.util.concurrent.atomic.AtomicReference;
    import org.jspecify.annotations.NullUnmarked;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.junit.runners.JUnit4;
    
    /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

     */
    package jcifs.internal.smb2.rdma;
    
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.util.EnumSet;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    /**
     * RDMA buffer manager for efficient memory region pooling.
     *
     * Manages pools of pre-registered memory regions to avoid the overhead
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/TagsTest.kt

     * limitations under the License.
     */
    package okhttp3.internal
    
    import assertk.assertThat
    import assertk.assertions.isEqualTo
    import assertk.assertions.isNull
    import java.util.concurrent.atomic.AtomicReference
    import org.junit.jupiter.api.Test
    
    class TagsTest {
      @Test
      fun emptyTags() {
        val tags = EmptyTags
        assertThat(tags[String::class]).isNull()
      }
    
      @Test
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 24 11:37:46 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

    import java.lang.ref.ReferenceQueue;
    import java.lang.ref.WeakReference;
    import java.net.ServerSocket;
    import java.net.URL;
    import java.net.URLClassLoader;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicBoolean;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    import org.junit.After;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.junit.runners.JUnit4;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:07:52 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"net/http"
    	"net/textproto"
    	"regexp"
    	"strings"
    	"sync/atomic"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/handlers"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/logger"
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.4K bytes
    - Viewed (1)
  6. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

    import com.google.errorprone.annotations.concurrent.LazyInit;
    import java.util.concurrent.Callable;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicReference;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Serializes execution of tasks, somewhat like an "asynchronous {@code synchronized} block." Each
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.VisibleForTesting;
    import com.google.j2objc.annotations.ReflectionSupport;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.concurrent.locks.AbstractOwnableSynchronizer;
    import java.util.concurrent.locks.LockSupport;
    import org.jspecify.annotations.Nullable;
    
    @GwtCompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

    import java.lang.Thread.UncaughtExceptionHandler;
    import java.util.Locale;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.atomic.AtomicLong;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A ThreadFactory builder, providing any combination of these features:
     *
     * <ul>
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:35:26 UTC 2025
    - 9K bytes
    - Viewed (0)
  9. cmd/admin-handlers-site-replication.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/gob"
    	"encoding/json"
    	"errors"
    	"io"
    	"net/http"
    	"strings"
    	"sync/atomic"
    	"time"
    
    	"github.com/dustin/go-humanize"
    	"github.com/minio/madmin-go/v3"
    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/policy"
    )
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  10. src/cmd/asm/internal/arch/arm64.go

    	case arm64.ASTLXRB, arm64.ASTLXRH, arm64.ASTLXRW, arm64.ASTLXR,
    		arm64.ASTXRB, arm64.ASTXRH, arm64.ASTXRW, arm64.ASTXR,
    		arm64.ASTXP, arm64.ASTXPW, arm64.ASTLXP, arm64.ASTLXPW:
    		return true
    	}
    	// LDADDx/SWPx/CASx atomic instructions
    	return arm64.IsAtomicInstruction(op)
    }
    
    // IsARM64TBL reports whether the op (as defined by an arm64.A*
    // constant) is one of the TBL-like instructions and one of its
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Oct 16 00:35:29 UTC 2025
    - 6.3K bytes
    - Viewed (0)
Back to top