- Sort Score
- Result 10 results
- Languages All
Results 1841 - 1850 of 7,518 for THIS (0.03 sec)
-
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* it is invoked using this executor once the future's computation is {@linkplain Future#isDone() * complete}. If the computation has already completed when the listener is added, the listener will * execute immediately. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code * ListenableFuture}</a>. * * <p>This class is GWT-compatible. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFuture.java
* it is invoked using this executor once the future's computation is {@linkplain Future#isDone() * complete}. If the computation has already completed when the listener is added, the listener will * execute immediately. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/ListenableFutureExplained">{@code * ListenableFuture}</a>. * * <p>This class is GWT-compatible. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/SubscriberRegistry.java
*/ private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers = Maps.newConcurrentMap(); /** The event bus this registry belongs to. */ @Weak private final EventBus bus; SubscriberRegistry(EventBus bus) { this.bus = checkNotNull(bus); } /** Registers all subscriber methods on the given listener object. */ void register(Object listener) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 10.8K bytes - Viewed (0) -
docs/bucket/lifecycle/README.md
} } ] } ``` This JSON rule is equivalent to the following MinIO Client command: ``` mc ilm rule add --noncurrent-expire-days 30 --noncurrent-expire-newer 5 --prefix "user-uploads/" myminio/mydata ``` #### 3.2.a Automatic removal of noncurrent versions keeping only most recent ones immediately (MinIO only extension)Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 9.1K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/msrpc/MsrpcShareEnum.java
public class MsrpcShareEnum extends srvsvc.ShareEnumAll { class MsrpcShareInfo1 extends SmbShareInfo { MsrpcShareInfo1(final srvsvc.ShareInfo1 info1) { this.netName = info1.netname; this.type = info1.type; this.remark = info1.remark; } } /** * Creates a new request to enumerate shares on a server. *Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.5K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/BaseRequest.java
* Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
SequentialExecutor(Executor executor) { this.executor = Preconditions.checkNotNull(executor); } /** * Adds a task to the queue and makes sure a worker thread is running. * * <p>If this method throws, e.g. a {@code RejectedExecutionException} from the delegate executor, * execution of tasks will stop until a call to this method is made. */ @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.6K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java
throw new IllegalArgumentException("maxCountLimit must be non-negative"); } this.maxCountLimit = maxCountLimit; this.totalCount = new AtomicInteger(); this.counters = new ConcurrentHashMap<>(); this.problems = new ConcurrentHashMap<>(); this.filter = requireNonNull(filter, "filter"); } @Override
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jul 18 17:30:19 UTC 2025 - 11.4K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/HashCode.java
/** * Returns the value of this hash code as a byte array. The caller may modify the byte array; * changes to it will <i>not</i> be reflected in this {@code HashCode} object or any other arrays * returned by this method. */ // TODO(user): consider ByteString here, when that is available public abstract byte[] asBytes(); /** * Copies bytes from this hash code into {@code dest}. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 12.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/RegularImmutableTable.java
public int size() { return RegularImmutableTable.this.size(); } @Override Cell<R, C, V> get(int index) { return getCell(index); } @Override public boolean contains(@Nullable Object object) { if (object instanceof Cell) { Cell<?, ?, ?> cell = (Cell<?, ?, ?>) object; Object value = RegularImmutableTable.this.get(cell.getRowKey(), cell.getColumnKey());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Apr 08 13:05:15 UTC 2025 - 7K bytes - Viewed (0)