Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/alitto/pond
/ types & classes
Types & classes
30 in github.com/alitto/pond
⨍
Functions
262
◇
Types & classes
30
Interface
BasePool
BasePool defines methods common to all pool types.
pool.go:38
Struct
CompositeFuture
internal/future/composite.go:30
FuncType
CompositeFutureResolver
func(index int, value V, err error)
internal/future/composite.go:9
Struct
Future
A Future represents a value that will be available in the Future. It is always associated with a context that can be used to wait for the value to be
internal/future/future.go:12
FuncType
FutureResolver
func(err error)
internal/future/future.go:7
Struct
LinkedBuffer
LinkedBuffer implements an unbounded generic buffer that can be written to and read from concurrently. It is implemented using a linked list of buffer
internal/linkedbuffer/linkedbuffer.go:10
FuncType
Option
func(*pool)
pooloptions.go:7
Struct
Payload
internal/linkedbuffer/buffer_test.go:47
Interface
Pool
Represents a pool of goroutines that can execute tasks concurrently.
pool.go:96
Interface
Result
Result is deprecated. Use ResultTask instead. This interface is maintained for backward compatibility. Deprecated: Use ResultTask instead.
future.go:27
Interface
ResultPool
ResultPool is a pool that can be used to submit tasks that return a result.
result.go:10
Interface
ResultTask
ResultTask represents a task that yields a result. If the task fails, the error can be retrieved.
future.go:14
Interface
ResultTaskGroup
ResultTaskGroup represents a group of tasks that can be executed concurrently. As opposed to TaskGroup, the tasks in a ResultTaskGroup yield a result.
group.go:48
Interface
Task
Task represents a task that can be waited on. If the task fails, the error can be retrieved.
future.go:4
Interface
TaskGroup
TaskGroup represents a group of tasks that can be executed concurrently. The group can be waited on to block until all tasks have completed. If any of
group.go:17
Struct
ValueFuture
A Future represents a value that will be available in the Future. It is always associated with a context that can be used to wait for the value to be
internal/future/value.go:13
FuncType
ValueFutureResolver
func(value V, err error)
internal/future/value.go:8
Struct
abstractTaskGroup
group.go:75
Struct
buffer
buffer implements a generic buffer that can store any type of data. It is not thread-safe and should be used with a mutex. It is used by LinkedBuffer
internal/linkedbuffer/buffer.go:12
Struct
compositeErrorResolution
internal/future/composite.go:16
Struct
compositeResolution
internal/future/composite.go:11
Struct
futureResolution
internal/future/future.go:49
Struct
pool
pool.go:138
Struct
result
group.go:70
Struct
resultPool
result.go:47
Struct
resultTaskGroup
group.go:173
Struct
taskGroup
group.go:151
Struct
valueFutureResolution
internal/future/value.go:52
Struct
waitListener
internal/future/composite.go:25
Struct
wrappedTask
task.go:14