- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for aquele (0.32 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 7.5K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
// This dispatcher matches the original dispatch behavior of EventBus. /** Per-thread queue of events to dispatch. */ private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { return Queues.newArrayDeque(); } };
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
// This dispatcher matches the original dispatch behavior of EventBus. /** Per-thread queue of events to dispatch. */ private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { return Queues.newArrayDeque(); } };
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/converter/ReadingConverterChain.java
final Queue<String> queue = new LinkedList<>(); queue.add(text); final List<String> convertedTexts = new ArrayList<>(getMaxReadingNum()); convertedTexts.add(text); for (final ReadingConverter converter : converters) { String s; while ((s = queue.poll()) != null && convertedTexts.size() <= getMaxReadingNum()) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 1.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java
* */ public interface UrlQueueService<QUEUE extends UrlQueue<?>> { void updateSessionId(String oldSessionId, String newSessionId); void add(String sessionId, String url); void insert(QUEUE urlQueue); void delete(String sessionId); void deleteAll(); void offerAll(String sessionId, List<QUEUE> newUrlQueueList); QUEUE poll(String sessionId);
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 1.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestStringQueueGenerator.java
import java.util.List; import java.util.Queue; /** * Create queue of strings for tests. * * @author Jared Levy */ @GwtCompatible @ElementTypesAreNonnullByDefault public abstract class TestStringQueueGenerator implements TestQueueGenerator<String> { @Override public SampleElements<String> samples() { return new Strings(); } @Override public Queue<String> create(Object... elements) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Feb 21 16:49:06 UTC 2024 - 1.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/TreeTraverser.java
implements PeekingIterator<T> { private final Queue<T> queue; BreadthFirstIterator(T root) { this.queue = new ArrayDeque<>(); queue.add(root); } @Override public boolean hasNext() { return !queue.isEmpty(); } @Override public T peek() { return queue.element(); } @Override public T next() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 8.8K bytes - Viewed (0) -
build-logic-commons/module-identity/src/main/kotlin/gradlebuild.module-jar.gradle.kts
val seen = mutableSetOf<ResolvedVariantResult>() val queue = ArrayDeque<DependencyResult>() val rootDependencies = rootComponent.getDependenciesForVariant(rootVariant) seen.add(rootVariant) queue.addAll(rootDependencies) while (queue.isNotEmpty()) { val dependency = when (val result = queue.removeFirst()) { is ResolvedDependencyResult -> result
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 01 08:59:48 UTC 2024 - 4.4K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10SymbolDeclarationOverridesProvider.kt
): Collection<CallableMemberDescriptor> { val overriddenDescriptors = LinkedHashSet<CallableMemberDescriptor>() val queue = ArrayDeque<CallableMemberDescriptor>().apply { addAll(descriptor.overriddenDescriptors) } while (queue.isNotEmpty()) { val current = queue.removeFirst() if (current.kind != CallableMemberDescriptor.Kind.FAKE_OVERRIDE) { overriddenDescriptors.add(current)
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 22 06:28:35 UTC 2024 - 4.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java
import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.regex.Pattern; import org.codelibs.fess.crawler.entity.AccessResultImpl; import org.codelibs.fess.crawler.entity.UrlQueueImpl; /** * @author shinsuke * */ public class MemoryDataHelper { protected volatile Map<String, Queue<UrlQueueImpl<Long>>> urlQueueMap = new HashMap<>();
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 4.8K bytes - Viewed (0)