Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Balun-courses/concurrency_go
/ functions
Functions
875 in github.com/Balun-courses/concurrency_go
⨍
Functions
875
◇
Types & classes
175
↓ 1 callers
Method
Then
(successCb func(interface{}), errCb func(error))
lessons/6_lesson_channel_patterns/promise/main.go:31
↓ 1 callers
Method
Top
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:36
↓ 1 callers
Function
Transform
(in <-chan int)
lessons/6_lesson_channel_patterns/transformer/main.go:5
↓ 1 callers
Method
Unlock
()
additional/open_lessons/mutex_internals/broken_mutex_2/main.go:29
↓ 1 callers
Method
Unlock
additional/open_lessons/mutex_internals/memory_barriers/main.cpp:22
↓ 1 callers
Method
Unlock
()
additional/open_lessons/mutex_internals/spinlock_with_yield/main.go:25
↓ 1 callers
Method
Unlock
()
additional/open_lessons/mutex_internals/broken_mutex_1/main.go:28
↓ 1 callers
Method
Unlock
()
additional/open_lessons/mutex_internals/ticket_lock/main.go:22
↓ 1 callers
Method
Unlock
()
additional/open_lessons/mutex_internals/spinlock_combined/main.go:32
↓ 1 callers
Function
WaitToClose
Need to show solution
lessons/5_lesson_channels/nil_channel/main.go:10
↓ 1 callers
Function
WithContexCheck
(ctx context.Context, action func())
lessons/7_lesson_contexts_and_memory_barriers/with_ctx_check/main.go:5
↓ 1 callers
Function
WithCtxAfterFunc
context.AfterFunc
lessons/7_lesson_contexts_and_memory_barriers/after_done/main.go:11
↓ 1 callers
Function
WithServerBufferSize
(size uint)
database/internal/network/network_options.go:29
↓ 1 callers
Function
WithServerIdleTimeout
(timeout time.Duration)
database/internal/network/network_options.go:23
↓ 1 callers
Function
WithServerMaxConnectionsNumber
(count uint)
database/internal/network/network_options.go:35
↓ 1 callers
Function
WithTimeout
(parent Context, duration time.Duration)
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout_implementation/main.go:15
↓ 1 callers
Method
Write
([]byte)
database/internal/database/storage/wal/logs_writer.go:11
↓ 1 callers
Function
WriteFile
(file *os.File, data []byte)
database/internal/database/filesystem/utils.go:61
↓ 1 callers
Method
acquireLocks
(locks []*lock, txID int32)
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:86
↓ 1 callers
Function
async
Describe blocking
lessons/5_lesson_channels/channel_interaction/main.go:10
↓ 1 callers
Function
async1
()
lessons/5_lesson_channels/select/main.go:8
↓ 1 callers
Function
async2
()
lessons/5_lesson_channels/select/main.go:17
↓ 1 callers
Function
calculate
go test -bench=. perf_test.go a = 1 / ((1 - P) + (P / S))
lessons/9_lesson_concurrency_patterns/amdala/perf_test.go:12
↓ 1 callers
Function
consumer
(ch chan int)
lessons/5_lesson_channels/producer_consumer/main.go:15
↓ 1 callers
Function
consumer
()
lessons/5_lesson_channels/deadlock/main.go:11
↓ 1 callers
Function
consumer
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:55
↓ 1 callers
Method
copyLocked
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:201
↓ 1 callers
Function
cpOptimized
(input []string)
additional/lesson_testing_and_profiling/benchmark_profile/bench_test.go:37
↓ 1 callers
Method
delete
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:31
↓ 1 callers
Method
doOnce
(action func())
lessons/4_lesson_sync_primitives_2/once_implementation/once.go:27
↓ 1 callers
Function
done
(wg sync.WaitGroup)
lessons/3_lesson_sync_primitives_1/wait_group_copying/main.go:5
↓ 1 callers
Method
expungeLocked
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:61
↓ 1 callers
Function
gen
(numbers ...int)
lessons/6_lesson_channel_patterns/pipeline/main.go:5
↓ 1 callers
Function
goroutine1
()
lessons/3_lesson_sync_primitives_1/livelock/main.go:14
↓ 1 callers
Function
goroutine2
()
lessons/3_lesson_sync_primitives_1/livelock/main.go:28
↓ 1 callers
Function
handle1
()
lessons/3_lesson_sync_primitives_1/defer_with_panic/main.go:14
↓ 1 callers
Function
handle2
()
lessons/3_lesson_sync_primitives_1/defer_with_panic/main.go:27
↓ 1 callers
Method
handleConnection
(ctx context.Context, connection net.Conn, handler TCPHandler)
database/internal/network/tcp_server.go:91
↓ 1 callers
Method
handleDelQuery
(ctx context.Context, query compute.Query)
database/internal/database/database.go:95
↓ 1 callers
Method
handleGetQuery
(ctx context.Context, query compute.Query)
database/internal/database/database.go:83
↓ 1 callers
Method
handleResponse
(response Response)
database/internal/database/storage/replication/slave.go:119
↓ 1 callers
Method
handleSetQuery
(ctx context.Context, query compute.Query)
database/internal/database/database.go:74
↓ 1 callers
Function
in
(in chan<- int)
lessons/5_lesson_channels/unidirectional_channels/main.go:5
↓ 1 callers
Function
inc
()
lessons/3_lesson_sync_primitives_1/local_mutex/main.go:12
↓ 1 callers
Function
infiniteLoop
(str string)
lessons/2_lesson_gorutines_and_scheduler/async_preemptible/main.go:8
↓ 1 callers
Method
init
()
lessons/3_lesson_sync_primitives_1/lazy_initialization/main.go:19
↓ 1 callers
Function
initialize
()
lessons/4_lesson_sync_primitives_2/compare_and_swap/main.go:14
↓ 1 callers
Function
injectTraceID
(next http.Handler)
lessons/7_lesson_contexts_and_memory_barriers/context_with_http_server/main.go:28
↓ 1 callers
Function
loop
(str string)
lessons/2_lesson_gorutines_and_scheduler/async_preemptible/main.go:14
↓ 1 callers
Method
loop
()
lessons/9_lesson_concurrency_patterns/actors/actor.go:30
↓ 1 callers
Function
makeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_value/main.go:18
↓ 1 callers
Function
makeRequest
(_ context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_http_server/main.go:24
↓ 1 callers
Function
makeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_timeout/main.go:9
↓ 1 callers
Function
makeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_with_value_inheritance/main.go:13
↓ 1 callers
Function
makeRequest
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/context_inheritance_1/main.go:16
↓ 1 callers
Function
mul
(in <-chan int)
lessons/6_lesson_channel_patterns/pipeline/main.go:17
↓ 1 callers
Function
newActor
(executor Executor)
lessons/9_lesson_concurrency_patterns/actors/actor.go:20
↓ 1 callers
Function
newEntry
(value string)
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:16
↓ 1 callers
Function
newTransaction
(scheduler scheduler, id int32)
lessons/9_lesson_concurrency_patterns/mvcc/transaction.go:22
↓ 1 callers
Function
newTransaction
(scheduler scheduler, id int32)
lessons/9_lesson_concurrency_patterns/2pl/transaction.go:29
↓ 1 callers
Function
notifier
(signals chan struct{})
lessons/5_lesson_channels/signals/main.go:8
↓ 1 callers
Function
notifier
(signals chan int)
lessons/5_lesson_channels/broadcast/main.go:8
↓ 1 callers
Function
or
(channels ...<-chan struct{})
lessons/6_lesson_channel_patterns/or_channel/main.go:8
↓ 1 callers
Function
out
(out <-chan int)
lessons/5_lesson_channels/unidirectional_channels/main.go:10
↓ 1 callers
Function
parse
(in chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline/main.go:9
↓ 1 callers
Function
parse
(in chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline_with_fan_out/main.go:9
↓ 1 callers
Method
pop
()
lessons/4_lesson_sync_primitives_2/pool_implementation/main.go:23
↓ 1 callers
Function
process
(ctx context.Context)
lessons/7_lesson_contexts_and_memory_barriers/nil_context/main.go:7
↓ 1 callers
Function
process
()
lessons/2_lesson_gorutines_and_scheduler/panic_from_other_goroutine/main.go:8
↓ 1 callers
Method
processTasks
(workersNumber int)
lessons/10_lesson_live_coding_practise/worker_pool/main.go:30
↓ 1 callers
Function
producer
(ch chan int)
lessons/5_lesson_channels/producer_consumer/main.go:8
↓ 1 callers
Function
producer
()
lessons/5_lesson_channels/deadlock/main.go:20
↓ 1 callers
Function
producer
(ch chan<- struct{})
lessons/6_lesson_channel_patterns/ticker/main.go:8
↓ 1 callers
Function
producer
(ch chan<- struct{})
lessons/6_lesson_channel_patterns/timer/main.go:8
↓ 1 callers
Function
producer
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:49
↓ 1 callers
Function
publish
(name string, data map[string]string, c *sync.Cond)
lessons/4_lesson_sync_primitives_2/cond/main.go:21
↓ 1 callers
Method
push
(node *Node)
lessons/4_lesson_sync_primitives_2/pool_implementation/main.go:18
↓ 1 callers
Method
readSegment
(logs []Log, data []byte)
database/internal/database/storage/wal/logs_reader.go:48
↓ 1 callers
Method
receive
(message Message)
lessons/9_lesson_concurrency_patterns/actors/actor.go:36
↓ 1 callers
Function
receiveWeather
(ctx context.Context, result chan struct{}, idx int)
lessons/7_lesson_contexts_and_memory_barriers/context_with_cancel/main.go:11
↓ 1 callers
Method
releaseLocks
(locks []*lock)
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:100
↓ 1 callers
Function
request
(chan string)
lessons/6_lesson_channel_patterns/request_with_timeout/main.go:8
↓ 1 callers
Function
requests
()
lessons/4_lesson_sync_primitives_2/atomic_value/main.go:12
↓ 1 callers
Method
rollback
([]txOperation)
lessons/9_lesson_concurrency_patterns/2pl/transaction.go:13
↓ 1 callers
Method
rotateSegment
()
database/internal/database/filesystem/segment.go:42
↓ 1 callers
Method
saveWALSegment
(segmentName string, segmentData []byte)
database/internal/database/storage/replication/slave.go:136
↓ 1 callers
Function
send
(in <-chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline/main.go:22
↓ 1 callers
Function
send
(in <-chan string)
lessons/6_lesson_channel_patterns/parallel_pipeline_with_fan_out/main.go:22
↓ 1 callers
Function
setter
(data map[string]string)
lessons/4_lesson_sync_primitives_2/concurrent_map_writes/main.go:5
↓ 1 callers
Function
setup
()
lessons/7_lesson_contexts_and_memory_barriers/correct_memory_model_usage/main.go:12
↓ 1 callers
Function
setup
()
lessons/7_lesson_contexts_and_memory_barriers/incorrect_memory_model_usage/main.go:11
↓ 1 callers
Function
split
(inputCh <-chan string, n int)
lessons/6_lesson_channel_patterns/parallel_pipeline_with_fan_out/main.go:53
↓ 1 callers
Method
startPeriodicLeak
(interval time.Duration)
lessons/6_lesson_channel_patterns/rate_limiter/main.go:21
↓ 1 callers
Function
subscriber
(signals chan struct{})
lessons/5_lesson_channels/signals/main.go:12
↓ 1 callers
Method
synchronize
()
database/internal/database/storage/replication/slave.go:95
↓ 1 callers
Method
synchronize
(request Request)
database/internal/database/storage/replication/master.go:66
↓ 1 callers
Method
synchronize
(ctx context.Context)
lessons/10_lesson_live_coding_practise/cache/main.go:46
↓ 1 callers
Method
synchronize
(ctx context.Context)
lessons/8_lesson_sync_algorithms_and_lock_free/rcu/cache_with_atomic.go:24
↓ 1 callers
Method
synchronize
(ctx context.Context)
lessons/8_lesson_sync_algorithms_and_lock_free/rcu/cache_with_mutex.go:23
↓ 1 callers
Method
synchronizeImpl
(ctx context.Context)
lessons/10_lesson_live_coding_practise/cache/main.go:66
← previous
next →
301–400 of 875, ranked by callers