Index (OpenCode Base Parallel 1.0.0 API)

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form

A

acquire() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Acquires a permit, blocking until available.
allFailed(List) - Static method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Creates an all-failed exception.
andThen(Function) - Method in interface cloud.opencode.base.parallel.pipeline.TriFunction: Returns a composed function that first applies this function to its input, and then applies the after function to the result.
apply(T1, T2, T3) - Method in interface cloud.opencode.base.parallel.pipeline.TriFunction: Applies this function to the given arguments.
async(Runnable) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates an async runnable.
async(Supplier) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates an async supplier.
AsyncPipeline<T> - Class in cloud.opencode.base.parallel.pipeline: Async Pipeline - Asynchronous Processing Pipeline 异步流水线 - 异步处理流水线
AsyncPipeline(CompletableFuture) - Constructor for class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Constructs a new async pipeline.
availablePermits() - Method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter: Returns the current number of available permits (after refill).

B

BatchProcessor - Class in cloud.opencode.base.parallel.batch: Batch Processor - Parallel Batch Processing Utility 批处理器 - 并行批处理工具
BatchProcessor.BatchProgress - Record Class in cloud.opencode.base.parallel.batch: Batch progress information.
BatchProcessor.Builder - Class in cloud.opencode.base.parallel.batch: Builder for BatchProcessor.
BatchProgress(int, int, int) - Constructor for record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Creates an instance of a BatchProgress record class.
batchSize(int) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor.Builder: Sets the batch size.
build() - Method in class cloud.opencode.base.parallel.batch.BatchProcessor.Builder: Builds the processor.
build() - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig.Builder: Builds the config.
build() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor.Builder: Builds the HybridExecutor.
build() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor.Builder: Builds the executor.
build() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope.Builder: Builds the scope.
builder() - Static method in class cloud.opencode.base.parallel.batch.BatchProcessor: Creates a new builder.
builder() - Static method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Creates a new builder.
builder() - Static method in class cloud.opencode.base.parallel.executor.HybridExecutor: Creates a new builder.
builder() - Static method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Creates a builder for more configuration options.
builder() - Static method in class cloud.opencode.base.parallel.structured.ScheduledScope: Creates a builder for more configuration options.
burstCapacity(long) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor.Builder: Sets the burst capacity.

C

call(String, String, Callable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Calls a task with trace ID and user ID bound.
callWith(ScopedValue, T, Callable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Calls a task with a custom scoped value bound.
callWithTraceId(String, Callable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Calls a task with trace ID bound.
callWithUserId(String, Callable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Calls a task with user ID bound.
cancel(boolean) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Cancels the pipeline.
cancelled() - Static method in class cloud.opencode.base.parallel.structured.TaskResult: Creates a cancelled result.
CANCELLED - Enum constant in enum class cloud.opencode.base.parallel.structured.TaskResult.State: Task was cancelled - 任务被取消
Classes | 类 - Section in package cloud.opencode.base.parallel.batch
Classes | 类 - Section in package cloud.opencode.base.parallel.exception
Classes | 类 - Section in package cloud.opencode.base.parallel.executor
Classes | 类 - Section in package cloud.opencode.base.parallel.pipeline
Classes | 类 - Section in package cloud.opencode.base.parallel.structured
close() - Method in class cloud.opencode.base.parallel.batch.BatchProcessor: Shuts down the internal executor if it is not user-provided.
close() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor
close() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor
close() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor
close() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope
close() - Method in class cloud.opencode.base.parallel.structured.StructuredScope
cloud.opencode.base.parallel - module cloud.opencode.base.parallel: OpenCode Base Parallel Module OpenCode 基础并行模块
cloud.opencode.base.parallel - package cloud.opencode.base.parallel: OpenCode Parallel - Modern Parallel Computing Utilities OpenCode 并行 - 现代化并行计算工具
cloud.opencode.base.parallel.batch - package cloud.opencode.base.parallel.batch: Batch Package - Batch Processing Utilities 批处理包 - 批处理工具
cloud.opencode.base.parallel.deadline - package cloud.opencode.base.parallel.deadline
cloud.opencode.base.parallel.exception - package cloud.opencode.base.parallel.exception: Exception Package - Parallel Execution Exceptions 异常包 - 并行执行异常
cloud.opencode.base.parallel.executor - package cloud.opencode.base.parallel.executor: Executor Package - Virtual Thread Executors 执行器包 - 虚拟线程执行器
cloud.opencode.base.parallel.pipeline - package cloud.opencode.base.parallel.pipeline: Pipeline Package - Async Pipeline and Functions 流水线包 - 异步流水线和函数
cloud.opencode.base.parallel.structured - package cloud.opencode.base.parallel.structured: Structured Package - Structured Concurrency (JDK 25 JEP 499/501) 结构化包 - 结构化并发 (JDK 25 JEP 499/501)
combine(AsyncPipeline, BiFunction) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Combines with another pipeline.
combine(CompletableFuture, CompletableFuture, CompletableFuture, TriFunction) - Static method in class cloud.opencode.base.parallel.OpenParallel: Combines three futures with a combiner function.
combine(CompletableFuture, CompletableFuture, BiFunction) - Static method in class cloud.opencode.base.parallel.OpenParallel: Combines two futures with a combiner function.
completed(T) - Static method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Creates a pipeline with a completed value.
completedBatches() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Returns the value of the completedBatches record component.
Core Classes | 核心类 - Section in package cloud.opencode.base.parallel
CpuBound - Interface in cloud.opencode.base.parallel.executor: CPU-Bound Marker Interface CPU 密集型标记接口
cpuPoolSize(int) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor.Builder: Sets the CPU pool size (platform threads).
cpuThreadNamePrefix(String) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor.Builder: Sets the CPU thread name prefix.
create() - Static method in class cloud.opencode.base.parallel.executor.HybridExecutor: Creates a hybrid executor with default settings.
create() - Static method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Creates a new virtual executor.
create() - Static method in class cloud.opencode.base.parallel.structured.ScheduledScope: Creates a new scheduled scope.
create(double) - Static method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Creates a rate limited executor with specified permits per second.
create(double, long) - Static method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Creates a rate limited executor with specified rate and burst capacity.
current() - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext

D

deadline(Instant) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope.Builder: Sets the deadline.
DeadlineContext - Class in cloud.opencode.base.parallel.deadline: Deadline Context — ScopedValue-based deadline propagation for virtual threads 截止时间上下文 — 基于 ScopedValue 的虚拟线程截止时间传播
defaultProcessor() - Static method in class cloud.opencode.base.parallel.batch.BatchProcessor: Creates a default batch processor.
defaults() - Static method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Creates a default configuration.
delay(Duration, Supplier) - Static method in class cloud.opencode.base.parallel.OpenParallel: Delays execution.

E

equals(Object) - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class cloud.opencode.base.parallel.structured.TaskResult
Example | 示例 - Section in package cloud.opencode.base.parallel
execute(Runnable) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Executes a runnable, auto-selecting the pool based on type.
execute(Runnable) - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Submits a task using the underlying executor.
executeOnCpuPool(Runnable) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Executes a runnable on the CPU (platform thread) pool.
executeOnIoPool(Runnable) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Executes a runnable on the IO (virtual thread) pool.
executionFailed(String, Throwable) - Static method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Creates an execution failed exception.
executor(ExecutorService) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor.Builder: Sets the executor.
executor(ExecutorService) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor.Builder: Sets a custom executor service.
ExecutorConfig - Class in cloud.opencode.base.parallel.executor: Executor Config - Executor Configuration 执行器配置 - 执行器配置
ExecutorConfig.Builder - Class in cloud.opencode.base.parallel.executor: Builder for ExecutorConfig.

F

failed(Throwable) - Static method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Creates a pipeline with a failed value.
failure(Throwable) - Static method in class cloud.opencode.base.parallel.structured.TaskResult: Creates a failed result.
FAILURE - Enum constant in enum class cloud.opencode.base.parallel.structured.TaskResult.State: Task failed with exception - 任务因异常失败
filter(Predicate) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Filters the value.
flatMap(Function) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Flat maps the success value.
fork(Callable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks a task immediately.
fork(Callable) - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Forks a task in this scope.
forkAll(Iterable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks multiple tasks immediately.
forkAll(Iterable) - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Forks multiple tasks in this scope.
forkAll(Callable...) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks multiple tasks immediately.
forkAll(Callable...) - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Forks multiple tasks in this scope.
forkAt(Instant, Callable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks a task at a specific instant.
forkDelayed(Duration, Callable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks a task after a delay.
forkPeriodic(Duration, int, Callable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks a periodic task with a maximum number of executions.
forkPeriodicUntil(Duration, Instant, Callable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks a periodic task until deadline or scope close.
forkWithFixedDelay(Duration, int, Callable) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Forks a periodic task with delay between completion and next execution.

G

get() - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Gets the result, blocking if necessary.
get() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the value, throwing if failed.
get(Duration) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Gets the result with timeout.
getAvailablePermits() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the currently available permits.
getAvailablePermits() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the available permits (for limited executor).
getAverageWaitMillis() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the average wait time in milliseconds.
getBatchSize() - Method in class cloud.opencode.base.parallel.batch.BatchProcessor: Gets the batch size.
getBurstCapacity() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the burst capacity.
getCompletedCount() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Gets the total number of completed tasks.
getCompletedCount() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the number of completed tasks.
getCompletedCount() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the number of completed tasks.
getConfig() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the configuration.
getCpuSubmittedCount() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Gets the number of tasks submitted to the CPU pool.
getDeadline() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Gets the deadline if set.
getException() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the exception.
getExceptionOptional() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the exception as Optional.
getExecutor() - Static method in class cloud.opencode.base.parallel.OpenParallel: Gets the shared virtual thread executor.
getFailedCount() - Method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Gets the number of failed tasks.
getFailedCount() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Gets the total number of failed tasks.
getFailedCount() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the number of failed tasks.
getFailedCount() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the number of failed tasks.
getIoSubmittedCount() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Gets the number of tasks submitted to the IO pool.
getMaxConcurrency() - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Gets the maximum concurrency.
getMaxPermits() - Method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter: Returns the maximum bucket capacity (equal to permitsPerSecond rounded down, minimum 1).
getNamePrefix() - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Gets the thread name prefix.
getOptional() - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Gets the result as Optional.
getOrDefault(T) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Gets the result or default on error.
getOrDefault(T) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the value or default.
getOrElse(Function) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the value or computes from exception.
getOrNull() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the value or null.
getOrNull(ScopedValue) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Gets a scoped value or null.
getParallelism() - Method in class cloud.opencode.base.parallel.batch.BatchProcessor: Gets the parallelism.
getPartition(List, int, int) - Static method in class cloud.opencode.base.parallel.batch.PartitionUtil: Gets a specific partition by index.
getPendingCount() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the number of pending tasks.
getPendingScheduledCount() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Gets the number of pending scheduled futures.
getPermitsPerSecond() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the configured permits per second.
getPermitsPerSecond() - Method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter: Returns the configured permits per second.
getPolicy() - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Gets the policy.
getRejectedCount() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the number of rejected tasks (when using trySubmit).
getRemainingTime() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Gets the remaining time until deadline.
getRequestId() - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Gets the current request ID.
getState() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the state.
getSubmittedCount() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the number of submitted tasks.
getSubmittedCount() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the number of submitted tasks.
getSuccessCount() - Method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Gets the number of successful tasks.
getSuppressedExceptions() - Method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Gets the suppressed exceptions.
getTaskCount() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Gets the number of forked tasks.
getTaskCount() - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Gets the number of forked tasks.
getTaskTimeout() - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Gets the task timeout.
getTenantId() - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Gets the current tenant ID.
getTotalCount() - Method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Gets the total number of tasks.
getTotalWaitNanos() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the total wait time in nanoseconds.
getTraceId() - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Gets the current trace ID.
getTraceIdOrDefault(String) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Gets the current trace ID or default.
getUncaughtExceptionHandler() - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Gets the uncaught exception handler.
getUserId() - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Gets the current user ID.
getWaitedCount() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Gets the number of tasks that waited for a permit.

H

handle(BiFunction) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Handles both success and error.
hashCode() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Returns a hash code value for this object.
hashCode() - Method in class cloud.opencode.base.parallel.structured.TaskResult
HybridExecutor - Class in cloud.opencode.base.parallel.executor: Hybrid Executor - Hybrid Thread Executor 混合执行器 - 混合线程执行器
HybridExecutor.Builder - Class in cloud.opencode.base.parallel.executor: Builder for HybridExecutor.

I

ifCancelled(Runnable) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Executes action if cancelled.
ifFailure(Consumer) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Executes action if failure.
ifSuccess(Consumer) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Executes action if success.
inheritThreadLocals(boolean) - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig.Builder: Sets whether to inherit thread locals.
interrupted(InterruptedException) - Static method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Creates an interrupted exception.
invokeAll(Collection) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Submits multiple tasks and waits for all.
invokeAll(Collection) - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Submits multiple tasks and waits for all.
invokeAll(Collection, Duration) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Submits multiple tasks with timeout.
invokeAll(Collection, Duration) - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Submits multiple tasks with timeout.
invokeAll(Collection) - Static method in class cloud.opencode.base.parallel.OpenParallel: Invokes all suppliers in parallel and collects results.
invokeAll(Collection, Duration) - Static method in class cloud.opencode.base.parallel.OpenParallel: Invokes all suppliers in parallel with timeout.
invokeAll(Supplier...) - Static method in class cloud.opencode.base.parallel.OpenParallel: Invokes all suppliers in parallel and collects results.
invokeAll(List) - Static method in class cloud.opencode.base.parallel.OpenStructured: Invokes all tasks, failing fast if any task fails.
invokeAll(List, Duration) - Static method in class cloud.opencode.base.parallel.OpenStructured: Invokes all tasks with timeout.
invokeAllRateLimited(double, Supplier...) - Static method in class cloud.opencode.base.parallel.OpenParallel: Executes tasks with rate limiting.
invokeAny(Collection) - Static method in class cloud.opencode.base.parallel.OpenParallel: Invokes all and returns the first to complete.
invokeAny(Supplier...) - Static method in class cloud.opencode.base.parallel.OpenParallel: Invokes all and returns the first to complete.
invokeAny(List) - Static method in class cloud.opencode.base.parallel.OpenStructured: Invokes all tasks, returning first success.
invokeAny(List, Duration) - Static method in class cloud.opencode.base.parallel.OpenStructured: Invokes all tasks with timeout, returning first success.
invokeDelayed(Duration, Supplier) - Static method in class cloud.opencode.base.parallel.OpenParallel: Executes a delayed task.
invokePeriodic(Duration, int, Supplier) - Static method in class cloud.opencode.base.parallel.OpenParallel: Executes tasks at scheduled times and collects results.
ioThreadNamePrefix(String) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor.Builder: Sets the IO thread name prefix.
isBound() - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext
isBound(ScopedValue) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Checks if a scoped value is bound.
isCancelled() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Checks if the task was cancelled.
isComplete() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Checks if processing is complete.
isCompletedExceptionally() - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Checks if the pipeline completed exceptionally.
isDeadlinePassed() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Checks if the deadline has passed.
isDone() - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Checks if the pipeline is completed.
isExpired() - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext
isFailure() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Checks if the task failed.
isInheritThreadLocals() - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig: Checks if thread locals should be inherited.
isShutdown() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Checks if the executor is shut down.
isShutdown() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Checks if the executor is shutdown.
isShutdown() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Checks if the executor is shutdown.
isSuccess() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Checks if the task succeeded.
isTerminated() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Checks if the executor is terminated.
isTerminated() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Checks if the executor is terminated.

J

joinAll() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Waits for all scheduled tasks to complete and joins.
joinAll() - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Joins and returns all results.
joinAll(Duration) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Waits for all tasks with timeout.
joinAll(Duration) - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Joins with timeout and returns all results.
joinAndReduce(T, BiFunction) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Joins and reduces results.
joinAndReduce(T, BiFunction) - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Joins and reduces results.
joinAny() - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Joins and returns the first successful result (for SHUTDOWN_ON_SUCCESS).
joinAsResults() - Method in class cloud.opencode.base.parallel.structured.ScheduledScope: Joins and returns results as TaskResults.
joinAsResults() - Method in class cloud.opencode.base.parallel.structured.StructuredScope: Joins and returns results as TaskResults.

L

lastBatchSize() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Returns the value of the lastBatchSize record component.

M

map(Function) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Maps the success value.
maxConcurrency(int) - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig.Builder: Sets the maximum concurrency.

N

namePrefix(String) - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig.Builder: Sets the thread name prefix.
namePrefix(String) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor.Builder: Sets the thread name prefix (for default virtual thread executor).
newScopedValue() - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Creates a new scoped value.

O

of(double) - Static method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter: Creates a rate limiter with the specified permits per second.
of(Callable) - Static method in class cloud.opencode.base.parallel.structured.TaskResult: Creates a result from a callable.
of(CompletableFuture) - Static method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Creates a pipeline from a CompletableFuture.
onError(Function) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Handles errors with a recovery function.
onErrorAsync(Function) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Handles errors with an async recovery function.
OpenParallel - Class in cloud.opencode.base.parallel: Open Parallel - Parallel Computing Utility Open 并行 - 并行计算工具
OpenParallelException - Exception Class in cloud.opencode.base.parallel.exception: Open Parallel Exception - Parallel Execution Exception Open 并行异常 - 并行执行异常
OpenParallelException(String) - Constructor for exception class cloud.opencode.base.parallel.exception.OpenParallelException: Constructs a new parallel exception with message.
OpenParallelException(String, Throwable) - Constructor for exception class cloud.opencode.base.parallel.exception.OpenParallelException: Constructs a new parallel exception with message and cause.
OpenParallelException(String, List, int, int) - Constructor for exception class cloud.opencode.base.parallel.exception.OpenParallelException: Constructs a new parallel exception with full details.
OpenStructured - Class in cloud.opencode.base.parallel: Open Structured - Structured Concurrency Facade (JDK 25 JEP 499) Open 结构化 - 结构化并发门面 (JDK 25 JEP 499)

P

parallel(Callable, Callable, Callable, TriFunction) - Static method in class cloud.opencode.base.parallel.OpenStructured: Invokes three tasks in parallel and combines results.
parallel(Callable, Callable, BiFunction) - Static method in class cloud.opencode.base.parallel.OpenStructured: Invokes two tasks in parallel and combines results.
parallelism(int) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor.Builder: Sets the parallelism.
parallelMap(List, Function) - Static method in class cloud.opencode.base.parallel.OpenParallel: Maps items in parallel using stream.
parallelMap(List, Function, int) - Static method in class cloud.opencode.base.parallel.OpenParallel: Maps items in parallel with concurrency limit.
parallelMap(List, Function, int, Duration) - Static method in class cloud.opencode.base.parallel.OpenParallel: Maps items in parallel with concurrency limit and timeout.
partialFailure(List, int) - Static method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Creates a partial failure exception.
partition(Collection, int) - Static method in class cloud.opencode.base.parallel.batch.PartitionUtil: Partitions a collection into smaller lists of specified size.
partition(List, int) - Static method in class cloud.opencode.base.parallel.batch.PartitionUtil: Partitions a list into smaller lists of specified size.
partitionCount(int, int) - Static method in class cloud.opencode.base.parallel.batch.PartitionUtil: Calculates the number of partitions.
partitionInto(List, int) - Static method in class cloud.opencode.base.parallel.batch.PartitionUtil: Partitions into a specified number of partitions.
partitionStream(List, int) - Static method in class cloud.opencode.base.parallel.batch.PartitionUtil: Creates a stream of partitions (lazy evaluation).
PartitionUtil - Class in cloud.opencode.base.parallel.batch: Partition Util - List Partition Utility 分区工具 - 列表分区工具
peek(Consumer) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Peeks at the value without transforming it.
percentage() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Gets the progress percentage.
permitsPerSecond(double) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor.Builder: Sets the permits per second.
pipeline(CompletableFuture) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates an async pipeline from existing future.
pipeline(Supplier) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates an async pipeline from initial supplier.
process(List, Consumer) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor: Processes items in batches.
processAndCollect(List, Function) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor: Processes items in batches with result collection.
processBatch(List, int, Consumer) - Static method in class cloud.opencode.base.parallel.OpenParallel: Processes items in batches.
processBatchAndCollect(List, int, Function) - Static method in class cloud.opencode.base.parallel.OpenParallel: Processes items in batches with result collection.
processWithProgress(List, Consumer, Consumer) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor: Processes items in batches with progress callback.

R

race(Callable...) - Static method in class cloud.opencode.base.parallel.OpenStructured: Races multiple tasks, returning the first to complete.
rateLimited(double) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates a rate limited executor with specified permits per second.
rateLimited(double, long) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates a rate limited executor with specified rate and burst capacity.
RateLimitedExecutor - Class in cloud.opencode.base.parallel.executor: Rate Limited Executor - Token Bucket Rate Limiting Executor 限速执行器 - 令牌桶限速执行器
RateLimitedExecutor.Builder - Class in cloud.opencode.base.parallel.executor: Builder for RateLimitedExecutor.
recover(Function) - Method in class cloud.opencode.base.parallel.structured.TaskResult: Recovers from failure.
remaining() - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext
REQUEST_ID - Static variable in class cloud.opencode.base.parallel.structured.ScopedContext: Request ID scoped value - 请求 ID 作用域值
run(String, String, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with trace ID and user ID bound.
run(String, String, String, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with trace ID, user ID, and tenant ID bound.
runAfter(AsyncPipeline) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Runs after another pipeline completes.
runAll(Runnable...) - Static method in class cloud.opencode.base.parallel.OpenParallel: Runs all tasks in parallel, waiting for completion.
runAll(Collection) - Static method in class cloud.opencode.base.parallel.OpenParallel: Runs all tasks in parallel, waiting for completion.
runAll(Collection, Duration) - Static method in class cloud.opencode.base.parallel.OpenParallel: Runs all tasks in parallel with timeout.
runAllWithContext(ScopedValue, T, List) - Static method in class cloud.opencode.base.parallel.OpenStructured: Runs multiple tasks with a scoped value bound.
runWith(ScopedValue, T, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with a custom scoped value bound.
runWithContext(ScopedValue, T, Callable) - Static method in class cloud.opencode.base.parallel.OpenStructured: Runs a task with a scoped value bound.
runWithRequestId(String, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with request ID bound.
runWithTenantId(String, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with tenant ID bound.
runWithTraceId(String, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with trace ID bound.
runWithUserId(String, Runnable) - Static method in class cloud.opencode.base.parallel.structured.ScopedContext: Runs a task with user ID bound.

S

scheduledScope() - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates a new scheduled scope for structured concurrency with scheduling.
scheduledScope(Duration) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates a scheduled scope with timeout.
scheduledScope(Instant) - Static method in class cloud.opencode.base.parallel.OpenParallel: Creates a scheduled scope with deadline.
ScheduledScope<T> - Class in cloud.opencode.base.parallel.structured: Scheduled Scope - Scheduled Structured Concurrency (JDK 25 JEP 499) 定时作用域 - 定时结构化并发 (JDK 25 JEP 499)
ScheduledScope.Builder<T> - Class in cloud.opencode.base.parallel.structured: Builder for ScheduledScope.
schedulerThreads(int) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope.Builder: Sets the number of scheduler threads.
scope() - Static method in class cloud.opencode.base.parallel.OpenStructured: Creates a structured scope with shutdown-on-failure policy.
scopeAny() - Static method in class cloud.opencode.base.parallel.OpenStructured: Creates a structured scope with shutdown-on-success policy.
ScopedContext - Class in cloud.opencode.base.parallel.structured: Scoped Context - Scoped Values Context Management (JDK 25 JEP 501) 作用域上下文 - 作用域值上下文管理 (JDK 25 JEP 501)
shared() - Static method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Gets the shared virtual executor.
shutdown() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Shuts down both pools gracefully.
shutdown() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Shuts down the executor.
shutdown() - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Shuts down the executor.
SHUTDOWN_ON_FAILURE - Enum constant in enum class cloud.opencode.base.parallel.structured.StructuredScope.Policy: Shutdown on first failure - 首次失败时关闭
SHUTDOWN_ON_SUCCESS - Enum constant in enum class cloud.opencode.base.parallel.structured.StructuredScope.Policy: Shutdown on first success - 首次成功时关闭
shutdownAndAwait(Duration) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Shuts down and waits for termination of both pools.
shutdownAndAwait(Duration) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Shuts down and waits for termination.
shutdownAndAwait(Duration) - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Shuts down and waits for termination.
shutdownNow() - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Shuts down both pools immediately.
shutdownOnFailure() - Static method in class cloud.opencode.base.parallel.structured.StructuredScope: Creates a scope that shuts down on first failure.
shutdownOnSuccess() - Static method in class cloud.opencode.base.parallel.structured.StructuredScope: Creates a scope that shuts down on first success.
stopOnError(boolean) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor.Builder: Sets whether to stop on error.
StructuredScope<T> - Class in cloud.opencode.base.parallel.structured: Structured Scope - Structured Concurrency Wrapper (JDK 25 JEP 499) 结构化作用域 - 结构化并发包装器 (JDK 25 JEP 499)
StructuredScope.Policy - Enum Class in cloud.opencode.base.parallel.structured: Shutdown policy enumeration.
submit(Runnable) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Submits a runnable task, waiting for a permit if necessary.
submit(Runnable) - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Submits a runnable task.
submit(Runnable, Duration) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Submits a runnable task with timeout for acquiring permit.
submit(Callable) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Submits a callable, auto-selecting the pool based on type.
submit(Callable) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Submits a callable task, waiting for a permit if necessary.
submit(Callable) - Method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Submits a callable task.
submit(Callable, Duration) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Submits a callable task with timeout for acquiring permit.
submitOnCpuPool(Callable) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Submits a callable on the CPU (platform thread) pool.
submitOnIoPool(Callable) - Method in class cloud.opencode.base.parallel.executor.HybridExecutor: Submits a callable on the IO (virtual thread) pool.
Sub-packages | 子包 - Section in package cloud.opencode.base.parallel
success(T) - Static method in class cloud.opencode.base.parallel.structured.TaskResult: Creates a successful result.
SUCCESS - Enum constant in enum class cloud.opencode.base.parallel.structured.TaskResult.State: Task completed successfully - 任务成功完成

T

TaskResult<T> - Class in cloud.opencode.base.parallel.structured: Task Result - Structured Task Result Wrapper 任务结果 - 结构化任务结果包装器
TaskResult.State - Enum Class in cloud.opencode.base.parallel.structured: Task state enumeration.
taskTimeout(Duration) - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig.Builder: Sets the task timeout.
TENANT_ID - Static variable in class cloud.opencode.base.parallel.structured.ScopedContext: Tenant ID scoped value - 租户 ID 作用域值
then(Function) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Applies a transformation function.
thenAsync(Function) - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Applies an async transformation function.
timeout(Duration) - Method in class cloud.opencode.base.parallel.batch.BatchProcessor.Builder: Sets the timeout.
timeout(Duration) - Static method in exception class cloud.opencode.base.parallel.exception.OpenParallelException: Creates a timeout exception.
timeout(Duration) - Method in class cloud.opencode.base.parallel.structured.ScheduledScope.Builder: Sets the timeout (deadline from now).
toFuture() - Method in class cloud.opencode.base.parallel.pipeline.AsyncPipeline: Gets the underlying CompletableFuture.
TokenBucketRateLimiter - Class in cloud.opencode.base.parallel.executor: Token Bucket Rate Limiter - Standalone non-blocking rate limiter.
toOptional() - Method in class cloud.opencode.base.parallel.structured.TaskResult: Gets the value as Optional.
toString() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Returns a string representation of this record class.
toString() - Method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter
toString() - Method in class cloud.opencode.base.parallel.structured.TaskResult
totalBatches() - Method in record class cloud.opencode.base.parallel.batch.BatchProcessor.BatchProgress: Returns the value of the totalBatches record component.
TRACE_ID - Static variable in class cloud.opencode.base.parallel.structured.ScopedContext: Trace ID scoped value - 追踪 ID 作用域值
TriFunction<T1,T2,T3,R> - Interface in cloud.opencode.base.parallel.pipeline: Tri Function - Three-Argument Function Interface 三元函数 - 三参数函数接口
tryAcquire() - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Tries to acquire a permit without waiting.
tryAcquire() - Method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter: Tries to acquire a single permit without blocking.
tryAcquire(int) - Method in class cloud.opencode.base.parallel.executor.TokenBucketRateLimiter: Tries to acquire the specified number of permits without blocking.
tryAcquire(Duration) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Tries to acquire a permit with timeout.
trySubmit(Runnable) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Tries to submit a runnable task without waiting.
trySubmit(Callable) - Method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Tries to submit a callable task without waiting.

U

uncaughtExceptionHandler(Thread.UncaughtExceptionHandler) - Method in class cloud.opencode.base.parallel.executor.ExecutorConfig.Builder: Sets the uncaught exception handler.
USER_ID - Static variable in class cloud.opencode.base.parallel.structured.ScopedContext: User ID scoped value - 用户 ID 作用域值

V

valueOf(String) - Static method in enum class cloud.opencode.base.parallel.structured.StructuredScope.Policy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class cloud.opencode.base.parallel.structured.TaskResult.State: Returns the enum constant of this class with the specified name.
values() - Static method in enum class cloud.opencode.base.parallel.structured.StructuredScope.Policy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class cloud.opencode.base.parallel.structured.TaskResult.State: Returns an array containing the constants of this enum class, in the order they are declared.
VirtualExecutor - Class in cloud.opencode.base.parallel.executor: Virtual Executor - Virtual Thread Executor 虚拟执行器 - 虚拟线程执行器

W

withConcurrency(int) - Static method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Creates a virtual executor with concurrency limit.
withConfig(ExecutorConfig) - Static method in class cloud.opencode.base.parallel.executor.VirtualExecutor: Creates a virtual executor with configuration.
withCpuPoolSize(int) - Static method in class cloud.opencode.base.parallel.executor.HybridExecutor: Creates a hybrid executor with the specified CPU pool size.
withDeadline(Instant) - Static method in class cloud.opencode.base.parallel.structured.ScheduledScope: Creates a scheduled scope with deadline.
withDeadline(Instant, Runnable) - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext
withDeadline(Instant, Callable) - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext
withExecutor(ExecutorService, double, long) - Static method in class cloud.opencode.base.parallel.executor.RateLimitedExecutor: Creates a rate limited executor with custom executor service.
withTimeout(Duration) - Static method in class cloud.opencode.base.parallel.structured.ScheduledScope: Creates a scheduled scope with timeout (deadline from now).
withTimeout(Duration, Runnable) - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext
withTimeout(Duration, Callable) - Static method in class cloud.opencode.base.parallel.deadline.DeadlineContext

A B C D E F G H I J L M N O P R S T U V W
All Classes and Interfaces|All Packages|Serialized Form