- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for ConcurrentLinkedQueue (1.02 sec)
-
android/guava/src/com/google/common/collect/Queues.java
return deque; } // ConcurrentLinkedQueue /** Creates an empty {@code ConcurrentLinkedQueue}. */ @J2ktIncompatible @GwtIncompatible // ConcurrentLinkedQueue public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() { return new ConcurrentLinkedQueue<>(); } /** * Creates a {@code ConcurrentLinkedQueue} containing the elements of the specified iterable, in
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.3K bytes - Viewed (0) -
guava/src/com/google/common/collect/Queues.java
return deque; } // ConcurrentLinkedQueue /** Creates an empty {@code ConcurrentLinkedQueue}. */ @J2ktIncompatible @GwtIncompatible // ConcurrentLinkedQueue public static <E> ConcurrentLinkedQueue<E> newConcurrentLinkedQueue() { return new ConcurrentLinkedQueue<>(); } /** * Creates a {@code ConcurrentLinkedQueue} containing the elements of the specified iterable, in
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
/** * The queue of ciphers for encryption. */ protected Queue<Cipher> encryptoQueue = new ConcurrentLinkedQueue<>(); /** * The queue of ciphers for decryption. */ protected Queue<Cipher> decryptoQueue = new ConcurrentLinkedQueue<>(); /** * Encrypts the given data. * * @param data * the data to encrypt
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat Jul 05 00:11:05 UTC 2025 - 11.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchLogHelper.java
protected int userInfoCacheSize = 10000; /** Queue for storing search logs. */ protected Queue<SearchLog> searchLogQueue = new ConcurrentLinkedQueue<>(); /** Queue for storing click logs. */ protected Queue<ClickLog> clickLogQueue = new ConcurrentLinkedQueue<>(); /** Cache for storing user information. */ protected LoadingCache<String, UserInfo> userInfoCache;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 26.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.connection import java.net.Socket import java.util.concurrent.ConcurrentLinkedQueue import java.util.concurrent.ThreadLocalRandom import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicReferenceFieldUpdater import okhttp3.Address import okhttp3.ConnectionPool
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jun 03 17:10:08 UTC 2025 - 16.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
import java.util.ArrayList; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.atomic.AtomicBoolean; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.CoreLibConstants;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 31K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/Helpers.java
* the size method */ public static <T extends @Nullable Object> Collection<T> misleadingSizeCollection(int delta) { // It would be nice to be able to return a real concurrent // collection like ConcurrentLinkedQueue, so that e.g. concurrent // iteration would work, but that would not be GWT-compatible. // We are not "just" inheriting from ArrayList here as this doesn't work for J2kt. return new AbstractList<T>() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Aug 10 19:54:19 UTC 2025 - 17.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/exec/CrawlerTest.java
import java.util.ArrayList; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.atomic.AtomicBoolean; import org.codelibs.core.io.FileUtil; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.misc.DynamicProperties;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 30.5K bytes - Viewed (0)