MCPcopy Create free account

hub / github.com/Balun-courses/concurrency_go / functions

Functions875 in github.com/Balun-courses/concurrency_go

↓ 1 callersMethodThen
(successCb func(interface{}), errCb func(error))
lessons/6_lesson_channel_patterns/promise/main.go:31
↓ 1 callersMethodTop
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:36
↓ 1 callersFunctionTransform
(in <-chan int)
lessons/6_lesson_channel_patterns/transformer/main.go:5
↓ 1 callersMethodUnlock
()
additional/open_lessons/mutex_internals/broken_mutex_2/main.go:29
↓ 1 callersMethodUnlock
additional/open_lessons/mutex_internals/memory_barriers/main.cpp:22
↓ 1 callersMethodUnlock
()
additional/open_lessons/mutex_internals/spinlock_with_yield/main.go:25
↓ 1 callersMethodUnlock
()
additional/open_lessons/mutex_internals/broken_mutex_1/main.go:28
↓ 1 callersMethodUnlock
()
additional/open_lessons/mutex_internals/ticket_lock/main.go:22
↓ 1 callersMethodUnlock
()
additional/open_lessons/mutex_internals/spinlock_combined/main.go:32
↓ 1 callersFunctionWaitToClose
Need to show solution
lessons/5_lesson_channels/nil_channel/main.go:10
↓ 1 callersFunctionWithContexCheck
(ctx context.Context, action func())
lessons/7_lesson_contexts_and_memory_barriers/with_ctx_check/main.go:5
↓ 1 callersFunctionWithCtxAfterFunc
context.AfterFunc
lessons/7_lesson_contexts_and_memory_barriers/after_done/main.go:11
↓ 1 callersFunctionWithServerBufferSize
(size uint)
database/internal/network/network_options.go:29
↓ 1 callersFunctionWithServerIdleTimeout
(timeout time.Duration)
database/internal/network/network_options.go:23
↓ 1 callersFunctionWithServerMaxConnectionsNumber
(count uint)
database/internal/network/network_options.go:35
↓ 1 callersFunctionWithTimeout
(parent Context, duration time.Duration)
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout_implementation/main.go:15
↓ 1 callersMethodWrite
([]byte)
database/internal/database/storage/wal/logs_writer.go:11
↓ 1 callersFunctionWriteFile
(file *os.File, data []byte)
database/internal/database/filesystem/utils.go:61
↓ 1 callersMethodacquireLocks
(locks []*lock, txID int32)
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:86
↓ 1 callersFunctionasync
Describe blocking
lessons/5_lesson_channels/channel_interaction/main.go:10
↓ 1 callersFunctionasync1
()
lessons/5_lesson_channels/select/main.go:8
↓ 1 callersFunctionasync2
()
lessons/5_lesson_channels/select/main.go:17
↓ 1 callersFunctioncalculate
go test -bench=. perf_test.go a = 1 / ((1 - P) + (P / S))
lessons/9_lesson_concurrency_patterns/amdala/perf_test.go:12
↓ 1 callersFunctionconsumer
(ch chan int)
lessons/5_lesson_channels/producer_consumer/main.go:15
↓ 1 callersFunctionconsumer
()
lessons/5_lesson_channels/deadlock/main.go:11
↓ 1 callersFunctionconsumer
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:55
↓ 1 callersMethodcopyLocked
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:201
↓ 1 callersFunctioncpOptimized
(input []string)
additional/lesson_testing_and_profiling/benchmark_profile/bench_test.go:37
↓ 1 callersMethoddelete
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:31
↓ 1 callersMethoddoOnce
(action func())
lessons/4_lesson_sync_primitives_2/once_implementation/once.go:27
↓ 1 callersFunctiondone
(wg sync.WaitGroup)
lessons/3_lesson_sync_primitives_1/wait_group_copying/main.go:5
↓ 1 callersMethodexpungeLocked
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:61
↓ 1 callersFunctiongen
(numbers ...int)
lessons/6_lesson_channel_patterns/pipeline/main.go:5
↓ 1 callersFunctiongoroutine1
()
lessons/3_lesson_sync_primitives_1/livelock/main.go:14
↓ 1 callersFunctiongoroutine2
()
lessons/3_lesson_sync_primitives_1/livelock/main.go:28
↓ 1 callersFunctionhandle1
()
lessons/3_lesson_sync_primitives_1/defer_with_panic/main.go:14
↓ 1 callersFunctionhandle2
()
lessons/3_lesson_sync_primitives_1/defer_with_panic/main.go:27
↓ 1 callersMethodhandleConnection
(ctx context.Context, connection net.Conn, handler TCPHandler)
database/internal/network/tcp_server.go:91
↓ 1 callersMethodhandleDelQuery
(ctx context.Context, query compute.Query)
database/internal/database/database.go:95
↓ 1 callersMethodhandleGetQuery
(ctx context.Context, query compute.Query)
database/internal/database/database.go:83
↓ 1 callersMethodhandleResponse
(response Response)
database/internal/database/storage/replication/slave.go:119
↓ 1 callersMethodhandleSetQuery
(ctx context.Context, query compute.Query)
database/internal/database/database.go:74
↓ 1 callersFunctionin
(in chan<- int)
lessons/5_lesson_channels/unidirectional_channels/main.go:5
↓ 1 callersFunctioninc
()
lessons/3_lesson_sync_primitives_1/local_mutex/main.go:12
↓ 1 callersFunctioninfiniteLoop
(str string)
lessons/2_lesson_gorutines_and_scheduler/async_preemptible/main.go:8
↓ 1 callersMethodinit
()
lessons/3_lesson_sync_primitives_1/lazy_initialization/main.go:19
↓ 1 callersFunctioninitialize
()
lessons/4_lesson_sync_primitives_2/compare_and_swap/main.go:14
↓ 1 callersFunctioninjectTraceID
(next http.Handler)
lessons/7_lesson_contexts_and_memory_barriers/context_with_http_server/main.go:28
↓ 1 callersFunctionloop
(str string)
lessons/2_lesson_gorutines_and_scheduler/async_preemptible/main.go:14
↓ 1 callersMethodloop
()
lessons/9_lesson_concurrency_patterns/actors/actor.go:30
↓ 1 callersFunctionmakeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_value/main.go:18
↓ 1 callersFunctionmakeRequest
(_ context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_http_server/main.go:24
↓ 1 callersFunctionmakeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout/main.go:9
↓ 1 callersFunctionmakeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_value_inheritance/main.go:13
↓ 1 callersFunctionmakeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_inheritance_1/main.go:16
↓ 1 callersFunctionmul
(in <-chan int)
lessons/6_lesson_channel_patterns/pipeline/main.go:17
↓ 1 callersFunctionnewActor
(executor Executor)
lessons/9_lesson_concurrency_patterns/actors/actor.go:20
↓ 1 callersFunctionnewEntry
(value string)
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:16
↓ 1 callersFunctionnewTransaction
(scheduler scheduler, id int32)
lessons/9_lesson_concurrency_patterns/mvcc/transaction.go:22
↓ 1 callersFunctionnewTransaction
(scheduler scheduler, id int32)
lessons/9_lesson_concurrency_patterns/2pl/transaction.go:29
↓ 1 callersFunctionnotifier
(signals chan struct{})
lessons/5_lesson_channels/signals/main.go:8
↓ 1 callersFunctionnotifier
(signals chan int)
lessons/5_lesson_channels/broadcast/main.go:8
↓ 1 callersFunctionor
(channels ...<-chan struct{})
lessons/6_lesson_channel_patterns/or_channel/main.go:8
↓ 1 callersFunctionout
(out <-chan int)
lessons/5_lesson_channels/unidirectional_channels/main.go:10
↓ 1 callersFunctionparse
(in chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline/main.go:9
↓ 1 callersFunctionparse
(in chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline_with_fan_out/main.go:9
↓ 1 callersMethodpop
()
lessons/4_lesson_sync_primitives_2/pool_implementation/main.go:23
↓ 1 callersFunctionprocess
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/nil_context/main.go:7
↓ 1 callersFunctionprocess
()
lessons/2_lesson_gorutines_and_scheduler/panic_from_other_goroutine/main.go:8
↓ 1 callersMethodprocessTasks
(workersNumber int)
lessons/10_lesson_live_coding_practise/worker_pool/main.go:30
↓ 1 callersFunctionproducer
(ch chan int)
lessons/5_lesson_channels/producer_consumer/main.go:8
↓ 1 callersFunctionproducer
()
lessons/5_lesson_channels/deadlock/main.go:20
↓ 1 callersFunctionproducer
(ch chan<- struct{})
lessons/6_lesson_channel_patterns/ticker/main.go:8
↓ 1 callersFunctionproducer
(ch chan<- struct{})
lessons/6_lesson_channel_patterns/timer/main.go:8
↓ 1 callersFunctionproducer
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:49
↓ 1 callersFunctionpublish
(name string, data map[string]string, c *sync.Cond)
lessons/4_lesson_sync_primitives_2/cond/main.go:21
↓ 1 callersMethodpush
(node *Node)
lessons/4_lesson_sync_primitives_2/pool_implementation/main.go:18
↓ 1 callersMethodreadSegment
(logs []Log, data []byte)
database/internal/database/storage/wal/logs_reader.go:48
↓ 1 callersMethodreceive
(message Message)
lessons/9_lesson_concurrency_patterns/actors/actor.go:36
↓ 1 callersFunctionreceiveWeather
(ctx context.Context, result chan struct{}, idx int)
lessons/7_lesson_contexts_and_memory_barriers/context_with_cancel/main.go:11
↓ 1 callersMethodreleaseLocks
(locks []*lock)
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:100
↓ 1 callersFunctionrequest
(chan string)
lessons/6_lesson_channel_patterns/request_with_timeout/main.go:8
↓ 1 callersFunctionrequests
()
lessons/4_lesson_sync_primitives_2/atomic_value/main.go:12
↓ 1 callersMethodrollback
([]txOperation)
lessons/9_lesson_concurrency_patterns/2pl/transaction.go:13
↓ 1 callersMethodrotateSegment
()
database/internal/database/filesystem/segment.go:42
↓ 1 callersMethodsaveWALSegment
(segmentName string, segmentData []byte)
database/internal/database/storage/replication/slave.go:136
↓ 1 callersFunctionsend
(in <-chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline/main.go:22
↓ 1 callersFunctionsend
(in <-chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline_with_fan_out/main.go:22
↓ 1 callersFunctionsetter
(data map[string]string)
lessons/4_lesson_sync_primitives_2/concurrent_map_writes/main.go:5
↓ 1 callersFunctionsetup
()
lessons/7_lesson_contexts_and_memory_barriers/correct_memory_model_usage/main.go:12
↓ 1 callersFunctionsetup
()
lessons/7_lesson_contexts_and_memory_barriers/incorrect_memory_model_usage/main.go:11
↓ 1 callersFunctionsplit
(inputCh <-chan string, n int)
lessons/6_lesson_channel_patterns/parallel_pipeline_with_fan_out/main.go:53
↓ 1 callersMethodstartPeriodicLeak
(interval time.Duration)
lessons/6_lesson_channel_patterns/rate_limiter/main.go:21
↓ 1 callersFunctionsubscriber
(signals chan struct{})
lessons/5_lesson_channels/signals/main.go:12
↓ 1 callersMethodsynchronize
()
database/internal/database/storage/replication/slave.go:95
↓ 1 callersMethodsynchronize
(request Request)
database/internal/database/storage/replication/master.go:66
↓ 1 callersMethodsynchronize
(ctx context.Context)
lessons/10_lesson_live_coding_practise/cache/main.go:46
↓ 1 callersMethodsynchronize
(ctx context.Context)
lessons/8_lesson_sync_algorithms_and_lock_free/rcu/cache_with_atomic.go:24
↓ 1 callersMethodsynchronize
(ctx context.Context)
lessons/8_lesson_sync_algorithms_and_lock_free/rcu/cache_with_mutex.go:23
↓ 1 callersMethodsynchronizeImpl
(ctx context.Context)
lessons/10_lesson_live_coding_practise/cache/main.go:66
← previousnext →301–400 of 875, ranked by callers