MCPcopy Create free account

hub / github.com/alitto/pond / functions

Functions262 in github.com/alitto/pond

⨍ Functions 262◇ Types & classes 30
FunctionTestResultTaskGroupWait
(t *testing.T)
group_test.go:14
FunctionTestResultTaskGroupWaitWithContextCanceledAndOngoingTasks
(t *testing.T)
group_test.go:131
FunctionTestResultTaskGroupWaitWithError
(t *testing.T)
group_test.go:38
FunctionTestResultTaskGroupWaitWithErrorInLastTask
(t *testing.T)
group_test.go:70
FunctionTestResultTaskGroupWaitWithMultipleErrors
(t *testing.T)
group_test.go:95
FunctionTestStopAndWaitWithGoexit
TestStopAndWaitWithGoexit reproduces issue #135: StopAndWait() blocks indefinitely when runtime.Goexit() is called inside a task. This commonly occurs
pool_test.go:741
FunctionTestSubmit
(t *testing.T)
default_test.go:12
FunctionTestSubmitWithError
(t *testing.T)
default_test.go:25
FunctionTestSubmitWithPanic
(t *testing.T)
default_test.go:36
FunctionTestSubpool
(t *testing.T)
subpool_test.go:14
FunctionTestSubpoolMaxConcurrency
(t *testing.T)
subpool_test.go:159
FunctionTestSubpoolMetrics
(t *testing.T)
subpool_test.go:86
FunctionTestSubpoolResize
(t *testing.T)
subpool_test.go:398
FunctionTestSubpoolStop
(t *testing.T)
subpool_test.go:130
FunctionTestSubpoolStopAndWait
(t *testing.T)
subpool_test.go:65
FunctionTestSubpoolStopAndWaitShouldNotDeadlockWhenContextCanceledWithQueuedTasks
(t *testing.T)
subpool_test.go:195
FunctionTestSubpoolStoppedAfterCancel
(t *testing.T)
subpool_test.go:175
FunctionTestSubpoolWithDifferentLimits
(t *testing.T)
subpool_test.go:253
FunctionTestSubpoolWithOverlappingConcurrency
(t *testing.T)
subpool_test.go:326
FunctionTestSubpoolWithQueueSizeOverride
(t *testing.T)
subpool_test.go:361
FunctionTestTaskGroupCanceledShouldSkipRemainingTasks
(t *testing.T)
group_test.go:283
FunctionTestTaskGroupContext
(t *testing.T)
group_test.go:470
FunctionTestTaskGroupDone
(t *testing.T)
group_test.go:363
FunctionTestTaskGroupMetrics
(t *testing.T)
group_test.go:382
FunctionTestTaskGroupMetricsWithCancelledContext
(t *testing.T)
group_test.go:410
FunctionTestTaskGroupStop
(t *testing.T)
group_test.go:338
FunctionTestTaskGroupWaitShouldNotDeadlockWhenPoolContextCanceledWithQueuedTasks
(t *testing.T)
group_test.go:183
FunctionTestTaskGroupWaitWithContextCanceledAndOngoingTasks
(t *testing.T)
group_test.go:157
FunctionTestTaskGroupWaitingTasks
(t *testing.T)
group_test.go:438
FunctionTestTaskGroupWithContextCanceled
(t *testing.T)
group_test.go:238
FunctionTestTaskGroupWithCustomContext
(t *testing.T)
group_test.go:311
FunctionTestTaskGroupWithNoTasks
(t *testing.T)
group_test.go:267
FunctionTestTaskGroupWithStoppedPool
(t *testing.T)
group_test.go:227
FunctionTestTaskInvokesGoexitAndPoolRecovers
TestTaskInvokesGoexitAndRecover
pool_test.go:764
FunctionTestValueFutureDone
(t *testing.T)
internal/future/value_test.go:58
FunctionTestValueFutureResolutionError
(t *testing.T)
internal/future/value_test.go:77
FunctionTestValueFutureWait
(t *testing.T)
internal/future/value_test.go:12
FunctionTestValueFutureWaitWithCanceledContext
(t *testing.T)
internal/future/value_test.go:42
FunctionTestValueFutureWaitWithError
(t *testing.T)
internal/future/value_test.go:26
MethodTrySubmit
(task func() R)
result.go:69
MethodTrySubmit
(task func())
pool.go:329
MethodTrySubmitErr
(task func() (R, error))
result.go:73
MethodTrySubmitErr
(task func() error)
pool.go:333
MethodWait
Waits for all tasks in the group to complete and returns the results of each task in the order they were submitted. If any of the tasks return an erro
group.go:61
MethodWait
()
group.go:165
MethodWait
()
group.go:187
MethodWait
Wait waits for the task to complete and returns the result and any error that occurred.
future.go:20
MethodWait
Wait waits for the task to complete and returns the result and any error that occurred.
future.go:33
MethodWait
Get waits for the future to complete and returns the output and any error that occurred.
internal/future/value.go:35
MethodWait
(count int)
internal/future/composite.go:88
MethodWaitingTasks
()
pool.go:219
MethodWrite
Write writes values to the buffer
internal/linkedbuffer/linkedbuffer.go:35
Functionmain
()
examples/prometheus/main.go:13
Functionmain
()
examples/task_group_context/main.go:11
Functionmain
()
examples/task_done/main.go:11
Functionmain
Pressing Ctrl+C while this program is running will cause the program to terminate gracefully. Tasks being processed will continue until they finish, b
examples/pool_context/main.go:15
Functionmain
()
examples/result_task/main.go:11
Functionmain
()
examples/task_group/main.go:42
FunctionnewBuffer
(capacity int)
internal/linkedbuffer/buffer.go:20
FunctionnewResultPool
(maxConcurrency int, parent *pool, options ...Option)
result.go:102
FunctionnewResultTaskGroup
(pool *pool, ctx context.Context)
group.go:217
Methodresolve
(index int, value V, err error)
internal/future/composite.go:117
← previous201–262 of 262, ranked by callers