索引

_

__enter__() （fish_async_task.task_status.ReadWriteLockContext 方法） __exit__() （fish_async_task.task_status.ReadWriteLockContext 方法） __init__() （fish_async_task.config.ConfigLoader 方法） __init__() （fish_async_task.config.HotReloadConfig 方法） __init__() （fish_async_task.performance.AdaptiveWorkerManager 方法） __init__() （fish_async_task.performance.BatchedStatusUpdater 方法） __init__() （fish_async_task.performance.PerformanceMetrics 方法） __init__() （fish_async_task.performance.PriorityTaskManager 方法）, [1] __init__() （fish_async_task.performance.PriorityTaskQueue 方法） __init__() （fish_async_task.performance.ShardedTaskStatus 方法） __init__() （fish_async_task.performance.SystemHealthMonitor 方法） __init__() （fish_async_task.performance.TaskDependencyManager 方法） __init__() （fish_async_task.performance.TaskResourceManager 方法）

__init__() （fish_async_task.performance.TaskStatusWithExpiry 方法） __init__() （fish_async_task.performance.TimeoutTaskTracker 方法） __init__() （fish_async_task.task_status.BatchedStatusUpdater 方法） __init__() （fish_async_task.task_status.ReadWriteLock 方法） __init__() （fish_async_task.task_status.ReadWriteLockContext 方法） __init__() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） __init__() （fish_async_task.task_status.TaskStatusManager 方法） __init__() （fish_async_task.TaskManager 方法）, [1] __init__() （fish_async_task.worker.AdaptiveWorkerManager 方法） __init__() （fish_async_task.worker.CPUMonitor 方法） __init__() （fish_async_task.worker.TaskExecutor 方法） __init__() （fish_async_task.worker.WorkerManager 方法） __new__()（fish_async_task.TaskManager 静态方法）, [1]

A

acquire_read() （fish_async_task.task_status.ReadWriteLock 方法） acquire_write() （fish_async_task.task_status.ReadWriteLock 方法） AdaptiveWorkerManager（fish_async_task.performance 中的类） AdaptiveWorkerManager（fish_async_task.worker 中的类）

add_cleanup_callback() （fish_async_task.worker.TaskExecutor 方法） add_dependency() （fish_async_task.performance.TaskDependencyManager 方法） add_task() （fish_async_task.performance.TaskStatusWithExpiry 方法） avg_task_time（fish_async_task.types.ScalingMetrics 属性）

B

BATCH_FLUSH_INTERVAL（fish_async_task.worker.TaskExecutor 属性） BATCH_SIZE（fish_async_task.worker.TaskExecutor 属性） BatchedStatusUpdater（fish_async_task.performance 中的类）

BatchedStatusUpdater（fish_async_task.task_status 中的类） BatchedUpdate（fish_async_task.types 中的类） buffer_size（fish_async_task.performance.BatchedStatusUpdater 属性）

C

cancel_task() （fish_async_task.performance.PriorityTaskManager 方法）, [1] check_and_flush() （fish_async_task.task_status.BatchedStatusUpdater 方法） cleanup_expired() （fish_async_task.performance.TaskStatusWithExpiry 方法） cleanup_expired() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） cleanup_old_task_status() （fish_async_task.task_status.TaskStatusManager 方法） cleanup_task_resources() （fish_async_task.performance.TaskResourceManager 方法） cleanup_timed_out_tasks() （fish_async_task.worker.TaskExecutor 方法） clear() （fish_async_task.performance.PriorityTaskQueue 方法） clear() （fish_async_task.performance.TaskDependencyManager 方法） clear_all() （fish_async_task.performance.ShardedTaskStatus 方法） clear_all() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法）

clear_cache() （fish_async_task.config.HotReloadConfig 方法） clear_task_status() （fish_async_task.task_status.TaskStatusManager 方法） clear_task_status() （fish_async_task.TaskManager 方法）, [1] close() （fish_async_task.performance.BatchedStatusUpdater 方法） ConfigLoader（fish_async_task.config 中的类） contains() （fish_async_task.performance.PriorityTaskQueue 方法） CPU_MULTIPLIER（fish_async_task.TaskManager 属性）, [1] cpu_threshold（fish_async_task.performance.AdaptiveWorkerManager 属性） cpu_usage（fish_async_task.types.ScalingMetrics 属性） CPUMonitor（fish_async_task.worker 中的类） current_workers（fish_async_task.types.ScalingMetrics 属性）

D

DEFAULT_ADAPTIVE_WORKER_ENABLED（fish_async_task.config.ConfigLoader 属性） DEFAULT_BATCH_FLUSH_INTERVAL（fish_async_task.task_status.TaskStatusManager 属性） DEFAULT_BATCH_SIZE（fish_async_task.task_status.TaskStatusManager 属性） DEFAULT_BATCH_UPDATE_BUFFER_SIZE（fish_async_task.config.ConfigLoader 属性） DEFAULT_BATCH_UPDATE_INTERVAL（fish_async_task.config.ConfigLoader 属性） DEFAULT_CLEANUP_INTERVAL（fish_async_task.TaskManager 属性）, [1] DEFAULT_CLEANUP_TIMEOUT（fish_async_task.performance.TaskResourceManager 属性） DEFAULT_CPU_THRESHOLD（fish_async_task.config.ConfigLoader 属性） DEFAULT_CPU_THRESHOLD（fish_async_task.worker.WorkerManager 属性） DEFAULT_ENABLE_ADAPTIVE_SCALING（fish_async_task.config.ConfigLoader 属性） DEFAULT_ENABLE_AUTO_CLEANUP（fish_async_task.config.ConfigLoader 属性） DEFAULT_ENABLE_BATCH_UPDATES（fish_async_task.config.ConfigLoader 属性） DEFAULT_IDLE_TIMEOUT（fish_async_task.TaskManager 属性）, [1] DEFAULT_MAX_CLEANUP_PER_BATCH（fish_async_task.task_status.TaskStatusManager 属性） DEFAULT_MAX_TASK_STATUS_COUNT（fish_async_task.TaskManager 属性）, [1] DEFAULT_MIN_MAX_WORKERS（fish_async_task.TaskManager 属性）, [1] DEFAULT_MIN_WORKERS（fish_async_task.TaskManager 属性）, [1]

DEFAULT_QUEUE_SIZE（fish_async_task.TaskManager 属性）, [1] DEFAULT_QUEUE_THRESHOLD_HIGH（fish_async_task.config.ConfigLoader 属性） DEFAULT_QUEUE_THRESHOLD_HIGH（fish_async_task.worker.WorkerManager 属性） DEFAULT_QUEUE_THRESHOLD_LOW（fish_async_task.config.ConfigLoader 属性） DEFAULT_QUEUE_THRESHOLD_LOW（fish_async_task.worker.WorkerManager 属性） DEFAULT_SCALE_DOWN_COOLDOWN（fish_async_task.config.ConfigLoader 属性） DEFAULT_SCALE_DOWN_COOLDOWN（fish_async_task.worker.WorkerManager 属性） DEFAULT_SCALE_UP_COOLDOWN（fish_async_task.config.ConfigLoader 属性） DEFAULT_SCALE_UP_COOLDOWN（fish_async_task.worker.WorkerManager 属性） DEFAULT_SHARD_COUNT（fish_async_task.config.ConfigLoader 属性） DEFAULT_SHARD_COUNT（fish_async_task.task_status.TaskStatusManager 属性） DEFAULT_TASK_EXPIRY（fish_async_task.performance.TimeoutTaskTracker 属性） DEFAULT_TASK_STATUS_TTL（fish_async_task.TaskManager 属性）, [1] DEFAULT_TASK_TIMEOUT（fish_async_task.TaskManager 属性）, [1] DEFAULT_THREAD_JOIN_TIMEOUT（fish_async_task.TaskManager 属性）, [1] DEFAULT_TIMEOUT（fish_async_task.task_status.ReadWriteLock 属性） destroy_instance()（fish_async_task.TaskManager 类方法）, [1]

E

empty() （fish_async_task.performance.PriorityTaskQueue 方法） enable_batch_update() （fish_async_task.task_status.TaskStatusManager 方法） end_time（fish_async_task.types.TaskStatusDict 属性） enforce_max_count() （fish_async_task.performance.TaskStatusWithExpiry 方法）

enforce_max_count() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） error（fish_async_task.types.TaskStatusDict 属性） execute_task() （fish_async_task.worker.TaskExecutor 方法） expiry_heaps（fish_async_task.task_status.ShardedTaskStatusWithExpiry 属性）

F

fish_async_task module fish_async_task.config module fish_async_task.performance module fish_async_task.task_status module fish_async_task.types module

fish_async_task.worker module flush() （fish_async_task.performance.BatchedStatusUpdater 方法） flush_interval（fish_async_task.performance.BatchedStatusUpdater 属性） flush_pending_updates() （fish_async_task.worker.TaskExecutor 方法） force_cleanup_task() （fish_async_task.performance.TaskResourceManager 方法） force_flush() （fish_async_task.task_status.BatchedStatusUpdater 方法） full() （fish_async_task.performance.PriorityTaskQueue 方法）

G

get() （fish_async_task.config.HotReloadConfig 方法） get() （fish_async_task.performance.PriorityTaskQueue 方法） get_adaptive_stats() （fish_async_task.worker.WorkerManager 方法） get_all() （fish_async_task.config.HotReloadConfig 方法） get_all_statuses() （fish_async_task.performance.ShardedTaskStatus 方法） get_all_statuses() （fish_async_task.performance.TaskStatusWithExpiry 方法） get_all_statuses() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） get_avg_task_time() （fish_async_task.performance.AdaptiveWorkerManager 方法） get_avg_task_time() （fish_async_task.worker.AdaptiveWorkerManager 方法） get_buffer_length() （fish_async_task.performance.BatchedStatusUpdater 方法） get_cpu_count() （fish_async_task.worker.CPUMonitor 方法） get_cpu_usage() （fish_async_task.performance.AdaptiveWorkerManager 方法） get_cpu_usage() （fish_async_task.worker.AdaptiveWorkerManager 方法） get_cpu_usage() （fish_async_task.worker.CPUMonitor 方法） get_health_status() （fish_async_task.performance.SystemHealthMonitor 方法） get_idle_time() （fish_async_task.worker.WorkerManager 方法） get_metrics() （fish_async_task.performance.PerformanceMetrics 方法） get_pending_count() （fish_async_task.performance.PriorityTaskManager 方法）, [1] get_pending_count() （fish_async_task.task_status.BatchedStatusUpdater 方法） get_pending_update_count() （fish_async_task.task_status.TaskStatusManager 方法） get_pending_update_count() （fish_async_task.worker.TaskExecutor 方法）

get_percentiles() （fish_async_task.performance.PerformanceMetrics 方法） get_queue_size() （fish_async_task.performance.PriorityTaskManager 方法）, [1] get_ready_tasks() （fish_async_task.performance.TaskDependencyManager 方法） get_resource_count() （fish_async_task.performance.TaskResourceManager 方法） get_scaling_metrics() （fish_async_task.performance.AdaptiveWorkerManager 方法） get_stats() （fish_async_task.performance.TaskDependencyManager 方法） get_stats() （fish_async_task.performance.TaskResourceManager 方法） get_stats() （fish_async_task.performance.TimeoutTaskTracker 方法） get_stats() （fish_async_task.worker.AdaptiveWorkerManager 方法） get_status() （fish_async_task.performance.ShardedTaskStatus 方法） get_status() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） get_task() （fish_async_task.performance.PriorityTaskManager 方法）, [1] get_task() （fish_async_task.performance.TaskStatusWithExpiry 方法） get_task_count() （fish_async_task.performance.ShardedTaskStatus 方法） get_task_count() （fish_async_task.performance.TaskStatusWithExpiry 方法） get_task_resource_count() （fish_async_task.performance.TaskResourceManager 方法） get_task_status() （fish_async_task.task_status.TaskStatusManager 方法） get_task_status() （fish_async_task.TaskManager 方法）, [1] get_timed_out_task_count() （fish_async_task.worker.TaskExecutor 方法） get_total_count() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） get_tracked_count() （fish_async_task.performance.TimeoutTaskTracker 方法）

H

has_circular_dependency() （fish_async_task.performance.TaskDependencyManager 方法） HEALTH_STATUS_GREEN（fish_async_task.performance.SystemHealthMonitor 属性）

HEALTH_STATUS_RED（fish_async_task.performance.SystemHealthMonitor 属性） HEALTH_STATUS_YELLOW（fish_async_task.performance.SystemHealthMonitor 属性） HotReloadConfig（fish_async_task.config 中的类）

I

is_empty() （fish_async_task.performance.PriorityTaskManager 方法）, [1]

is_ready() （fish_async_task.performance.TaskDependencyManager 方法）

L

last_scale_down_time（fish_async_task.types.ScalingMetrics 属性） last_scale_up_time（fish_async_task.types.ScalingMetrics 属性） load_adaptive_worker_config() （fish_async_task.config.ConfigLoader 方法） load_int_config() （fish_async_task.config.ConfigLoader 方法）

load_performance_config() （fish_async_task.config.ConfigLoader 方法） load_timeout_config() （fish_async_task.config.ConfigLoader 方法） logger（fish_async_task.config.HotReloadConfig 属性） logger（fish_async_task.performance.ShardedTaskStatus 属性） logger（fish_async_task.performance.TaskStatusWithExpiry 属性）

M

mark_completed() （fish_async_task.performance.TaskDependencyManager 方法） mark_failed() （fish_async_task.performance.TaskDependencyManager 方法） MAX_BATCH_UPDATE_BUFFER_SIZE（fish_async_task.config.ConfigLoader 属性） MAX_BATCH_UPDATE_INTERVAL（fish_async_task.config.ConfigLoader 属性） MAX_CLEANUP_INTERVAL（fish_async_task.config.ConfigLoader 属性） MAX_COOLDOWN（fish_async_task.config.ConfigLoader 属性） MAX_CPU_THRESHOLD（fish_async_task.config.ConfigLoader 属性） MAX_QUEUE_THRESHOLD（fish_async_task.config.ConfigLoader 属性） MAX_SHARD_COUNT（fish_async_task.config.ConfigLoader 属性） MAX_TASK_STATUS_COUNT（fish_async_task.config.ConfigLoader 属性） MAX_TASK_TIMEOUT（fish_async_task.config.ConfigLoader 属性）

MAX_TRACKED_RESOURCES（fish_async_task.performance.TaskResourceManager 属性） MAX_TRACKED_TIMEOUTS（fish_async_task.worker.TaskExecutor 属性） MAX_TTL（fish_async_task.config.ConfigLoader 属性） max_workers（fish_async_task.performance.AdaptiveWorkerManager 属性） min_workers（fish_async_task.performance.AdaptiveWorkerManager 属性） module fish_async_task fish_async_task.config fish_async_task.performance fish_async_task.task_status fish_async_task.types fish_async_task.worker

P

PerformanceMetrics（fish_async_task.performance 中的类） PriorityTaskManager（fish_async_task.performance 中的类）, [1]

PriorityTaskQueue（fish_async_task.performance 中的类） put() （fish_async_task.performance.PriorityTaskQueue 方法）

Q

qsize() （fish_async_task.performance.PriorityTaskQueue 方法） QUEUE_GET_TIMEOUT（fish_async_task.worker.WorkerManager 属性） QUEUE_PUT_TIMEOUT（fish_async_task.worker.WorkerManager 属性）

queue_size（fish_async_task.types.ScalingMetrics 属性） queue_threshold（fish_async_task.performance.AdaptiveWorkerManager 属性） queue_update() （fish_async_task.performance.BatchedStatusUpdater 方法）

R

ReadWriteLockContext（fish_async_task.task_status 中的类） ReadWriteLock（fish_async_task.task_status 中的类） record_cleanup() （fish_async_task.performance.PerformanceMetrics 方法） record_task_cancelled() （fish_async_task.performance.PerformanceMetrics 方法） record_task_completed() （fish_async_task.performance.PerformanceMetrics 方法） record_task_failed() （fish_async_task.performance.PerformanceMetrics 方法） record_task_submitted() （fish_async_task.performance.PerformanceMetrics 方法） record_task_time() （fish_async_task.performance.AdaptiveWorkerManager 方法） record_task_time() （fish_async_task.worker.AdaptiveWorkerManager 方法） record_task_time() （fish_async_task.worker.WorkerManager 方法） register_config() （fish_async_task.config.HotReloadConfig 方法） register_health_check() （fish_async_task.performance.SystemHealthMonitor 方法）

register_resource() （fish_async_task.performance.TaskResourceManager 方法） register_task() （fish_async_task.performance.TaskResourceManager 方法） release_read() （fish_async_task.task_status.ReadWriteLock 方法） release_write() （fish_async_task.task_status.ReadWriteLock 方法） reload() （fish_async_task.config.HotReloadConfig 方法） remove() （fish_async_task.performance.PriorityTaskQueue 方法） remove_status() （fish_async_task.performance.ShardedTaskStatus 方法） remove_status() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） reset() （fish_async_task.performance.PerformanceMetrics 方法） resize_shards() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） resize_shards() （fish_async_task.task_status.TaskStatusManager 方法） result（fish_async_task.types.TaskStatusDict 属性） rw_locks（fish_async_task.task_status.ShardedTaskStatusWithExpiry 属性）

S

scale_down_cooldown（fish_async_task.performance.AdaptiveWorkerManager 属性） scale_up_cooldown（fish_async_task.performance.AdaptiveWorkerManager 属性） scale_up_workers_if_needed() （fish_async_task.worker.WorkerManager 方法） ScalingMetrics（fish_async_task.types 中的类） send_shutdown_signals() （fish_async_task.worker.WorkerManager 方法） shard_count（fish_async_task.performance.ShardedTaskStatus 属性） shard_index（fish_async_task.types.ShardedTaskStatusDict 属性） ShardedTaskStatusDict（fish_async_task.types 中的类） ShardedTaskStatusWithExpiry（fish_async_task.task_status 中的类） ShardedTaskStatus（fish_async_task.performance 中的类） shards（fish_async_task.task_status.ShardedTaskStatusWithExpiry 属性） should_scale_down() （fish_async_task.performance.AdaptiveWorkerManager 方法） should_scale_down() （fish_async_task.worker.AdaptiveWorkerManager 方法） should_scale_down() （fish_async_task.worker.WorkerManager 方法）

should_scale_up() （fish_async_task.performance.AdaptiveWorkerManager 方法） should_scale_up() （fish_async_task.worker.AdaptiveWorkerManager 方法） shutdown() （fish_async_task.task_status.BatchedStatusUpdater 方法） shutdown() （fish_async_task.task_status.TaskStatusManager 方法） shutdown() （fish_async_task.TaskManager 方法）, [1] start() （fish_async_task.performance.TaskResourceManager 方法） start_initial_workers() （fish_async_task.worker.WorkerManager 方法） start_time（fish_async_task.types.TaskStatusDict 属性） status（fish_async_task.types.BatchedUpdate 属性） status（fish_async_task.types.TaskStatusDict 属性） stop() （fish_async_task.performance.TaskResourceManager 方法） submit_task() （fish_async_task.performance.PriorityTaskManager 方法）, [1] submit_task() （fish_async_task.TaskManager 方法）, [1] submit_time（fish_async_task.types.TaskStatusDict 属性） SystemHealthMonitor（fish_async_task.performance 中的类）

T

task_done() （fish_async_task.performance.PriorityTaskQueue 方法） task_id（fish_async_task.types.BatchedUpdate 属性） task_status（fish_async_task.types.ShardedTaskStatusDict 属性） TaskDependencyManager（fish_async_task.performance 中的类） TaskExecutor（fish_async_task.worker 中的类） TaskManager（fish_async_task 中的类）, [1] TaskQueueFullError, [1]

TaskResourceManager（fish_async_task.performance 中的类） TaskStatusDict（fish_async_task.types 中的类） TaskStatusManager（fish_async_task.task_status 中的类） TaskStatusWithExpiry（fish_async_task.performance 中的类） TIMEOUT_TASK_EXPIRY（fish_async_task.worker.TaskExecutor 属性） TimeoutTaskTracker（fish_async_task.performance 中的类） track_timeout_task() （fish_async_task.performance.TimeoutTaskTracker 方法） ttl（fish_async_task.performance.TaskStatusWithExpiry 属性）

U

underlying_store（fish_async_task.performance.BatchedStatusUpdater 属性） unregister_resource() （fish_async_task.performance.TaskResourceManager 方法） untrack_task() （fish_async_task.performance.TimeoutTaskTracker 方法） update() （fish_async_task.task_status.BatchedStatusUpdater 方法）

update_health_status() （fish_async_task.performance.SystemHealthMonitor 方法） update_status() （fish_async_task.performance.ShardedTaskStatus 方法） update_status() （fish_async_task.task_status.ShardedTaskStatusWithExpiry 方法） update_sync() （fish_async_task.performance.BatchedStatusUpdater 方法） update_task_status() （fish_async_task.task_status.TaskStatusManager 方法）

V

validate_config()（在 fish_async_task.config 模块中）

W

wait_for_threads_exit() （fish_async_task.worker.WorkerManager 方法）

worker_id（fish_async_task.types.TaskStatusDict 属性） WorkerManager（fish_async_task.worker 中的类）