Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 365 for atomic (0.44 sec)

  1. api/go1.17.txt

    pkg runtime/cgo (openbsd-amd64-cgo), type Handle uintptr
    pkg strconv, func QuotedPrefix(string) (string, error)
    pkg sync/atomic, method (*Value) CompareAndSwap(interface{}, interface{}) bool
    pkg sync/atomic, method (*Value) Swap(interface{}) interface{}
    pkg syscall (netbsd-386), const SYS_WAIT6 = 481
    pkg syscall (netbsd-386), const SYS_WAIT6 ideal-int
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 18K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

    import java.util.concurrent.ConcurrentSkipListMap;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.atomic.AtomicInteger;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Basher test for {@link ConcurrentHashMultiset}: start a bunch of threads, have each of them do
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

    import com.google.common.annotations.J2ktIncompatible;
    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.atomic.AtomicBoolean;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Utilities necessary for working with libraries that supply plain {@link Future} instances. Note
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java

    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.junit.jupiter.api.Test;
    
    /**
     * Security-focused test cases for BufferCache to verify buffer overflow protection.
     */
    public class BufferCacheSecurityTest {
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReaderTest.java

    import java.util.Collections;
    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.Map;
    import java.util.Random;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.suggest.Suggester;
    import org.codelibs.fess.suggest.settings.SuggestSettings;
    import org.codelibs.opensearch.runner.OpenSearchRunner;
    import org.junit.AfterClass;
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 9K bytes
    - Viewed (0)
  6. cmd/peer-s3-client.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"slices"
    	"sort"
    	"strconv"
    	"sync/atomic"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/grid"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    var errPeerOffline = errors.New("peer is offline")
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHookTest.java

     */
    package org.codelibs.fess.mylasta.direction.sponsor;
    
    import java.lang.reflect.Field;
    import java.lang.reflect.Method;
    import java.net.URL;
    import java.net.URLClassLoader;
    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.codelibs.fess.unit.UnitFessTestCase;
    import org.lastaflute.core.direction.FwAssistantDirector;
    import org.lastaflute.core.direction.FwCoreDirection;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  8. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  9. src/test/java/org/codelibs/fess/exec/ThumbnailGeneratorTest.java

    package org.codelibs.fess.exec;
    
    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.PrintStream;
    import java.lang.reflect.Method;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.core.misc.DynamicProperties;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.exception.ContainerNotAvailableException;
    import org.codelibs.fess.helper.SystemHelper;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 11.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java

     */
    package jcifs.internal.smb2.multichannel;
    
    import java.util.List;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.atomic.AtomicLong;
    
    import jcifs.SmbTransport;
    import jcifs.internal.CommonServerMessageBlock;
    
    /**
     * Information about a multi-channel connection
     */
    public class ChannelInfo {
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 10.6K bytes
    - Viewed (0)
Back to top