- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 365 for atomic (0.05 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/AccessTimeoutTarget.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.crawler.client; import java.util.concurrent.atomic.AtomicBoolean; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.core.timer.TimeoutTarget; /**
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java
assertEquals(Long.MIN_VALUE, crawlerContext.getMaxAccessCount()); } /** * Test access count atomic operations */ public void test_accessCountAtomicOperations() { // Verify atomic nature by checking return values assertEquals(1L, crawlerContext.incrementAndGetAccessCount()); assertEquals(2L, crawlerContext.incrementAndGetAccessCount());
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 25.6K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/ldap/LdapManagerTest.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.ldap; import java.util.ArrayList; import java.util.Hashtable; import java.util.List; import java.util.concurrent.atomic.AtomicBoolean; import org.codelibs.fess.helper.SystemHelper; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.unit.UnitFessTestCase; import org.codelibs.fess.util.ComponentUtil;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 5.2K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java
import com.google.caliper.BeforeExperiment; import com.google.caliper.Benchmark; import com.google.caliper.Param; import com.google.common.primitives.Ints; import java.util.Random; import java.util.concurrent.atomic.AtomicLong; import org.jspecify.annotations.NullUnmarked; /** * Single-threaded benchmark for {@link LoadingCache}. * * @author Charles Fry */ @NullUnmarked
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/FakeTicker.java
import com.google.common.base.Ticker; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.time.Duration; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; import org.jspecify.annotations.NullMarked; /** * A Ticker whose value can be advanced programmatically in test. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Apr 14 15:16:19 UTC 2025 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportPoolImpl.java
import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import jcifs.Address; import jcifs.CIFSContext; import jcifs.CIFSException; import jcifs.SmbConstants;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 33.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/SuppliersTest.java
import java.io.Serializable; import java.time.Duration; import java.util.ArrayList; import java.util.List; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Tests com.google.common.base.Suppliers. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 17.9K bytes - Viewed (0) -
cmd/update.go
package cmd import ( "bufio" "crypto" "crypto/tls" "encoding/hex" "errors" "fmt" "io" "net/http" "net/url" "os" "path" "path/filepath" "runtime" "strings" "sync/atomic" "time" "github.com/klauspost/compress/zstd" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/logger" "github.com/minio/pkg/v3/env" xnet "github.com/minio/pkg/v3/net"
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 18.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java
*/ package org.codelibs.fess.crawler.interval.impl; import java.net.URI; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicLong; import org.codelibs.core.exception.InterruptedRuntimeException; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.lang.SystemUtil; import org.codelibs.fess.crawler.entity.UrlQueue;
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 4.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.testing.NullPointerTester; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Unit tests for {@link ExecutionList}. * * @author Nishant Thakkar * @author Sven Mawson */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.7K bytes - Viewed (0)