- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 335 for atomics (0.04 sec)
-
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) -
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) -
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() } @TestRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 24 11:37:46 UTC 2025 - 7.1K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)