thread

type AbortPolicy struct{}

type CallerRunsPolicy struct{}

type DefaultThreadFactory struct{}

type DiscardOldestPolicy struct{}

type DiscardPolicy struct{}

type Executor interface {
	// Execute 在将来的某个时间执行给定的命令。
	// 该命令可以在新线程、池化线程或调用线程中执行，具体取决于 Executor 的实现。
	Execute(task func())
}

type ExecutorService interface {
	Executor

	// Shutdown 启动有序关闭，其中以前提交的任务将被执行，但不会接受新任务。
	Shutdown()

	// ShutdownNow 尝试停止所有正在执行的任务，暂停处理正在等待的任务，并返回等待执行的任务列表。
	ShutdownNow() []func()

	// IsShutdown 如果此执行程序已关闭，则返回 true。
	IsShutdown() bool

	// IsTerminated 如果关闭后所有任务都已完成，则返回 true。
	IsTerminated() bool

	// AwaitTermination 阻塞直到所有任务在关闭请求后完成，或发生超时，或当前线程被中断（以先发生者为准）。
	AwaitTermination(timeout time.Duration) bool
}

type RejectedExecutionHandler interface {
	// RejectedExecution 当 Execute 不能接受某个任务时调用此方法。
	// 为了解耦，这里传入 ThreadPool 接口而不是具体实现类。
	RejectedExecution(r func(), executor ThreadPool)
}

type ScheduledExecutorService interface {
	ExecutorService

	// Schedule 创建并执行在给定延迟后启用的一次性操作。
	Schedule(command func(), delay time.Duration) ScheduledFuture

	// ScheduleAtFixedRate 创建并执行一个在给定初始延迟后首次启用的定期操作，
	// 后续操作具有给定的周期；也就是将在 initialDelay 后开始执行，
	// 然后在 initialDelay+period 后执行，接着在 initialDelay + 2 * period 后执行，依此类推。
	ScheduleAtFixedRate(command func(), initialDelay time.Duration, period time.Duration) ScheduledFuture

	// ScheduleWithFixedDelay 创建并执行一个在给定初始延迟后首次启用的定期操作，
	// 随后，在每一次执行终止和下一次执行开始之间都存在给定的延迟。
	ScheduleWithFixedDelay(command func(), initialDelay time.Duration, delay time.Duration) ScheduledFuture
}

type ScheduledFuture interface {
	// GetDelay 返回剩余的延迟时间
	GetDelay() time.Duration
	// Cancel 取消任务
	Cancel(mayInterruptIfRunning bool) bool
	// IsCancelled 任务是否已取消
	IsCancelled() bool
	// IsDone 任务是否已完成
	IsDone() bool
}

type ScheduledThreadPoolExecutor struct {
	*ThreadPoolExecutor
	// contains filtered or unexported fields
}

type ThreadFactory interface {
	NewThread(runnable func())
}

type ThreadPool interface {
	ExecutorService
	// GetQueue 获取任务队列，DiscardOldestPolicy 需要用到它
	GetQueue() util.BlockingQueue[func()]
}

type ThreadPoolExecutor struct {
	// contains filtered or unexported fields
}