MCPcopy Create free account

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

Functions875 in github.com/Balun-courses/concurrency_go

⨍ Functions 875◇ Types & classes 175
↓ 2 callersFunctionnormalizeResources
(lhs, rhs *sync.Mutex)
lessons/3_lesson_sync_primitives_1/deadlock/main.go:10
↓ 2 callersFunctionnormalizeResources
(lhs, rhs *sync.Mutex)
lessons/3_lesson_sync_primitives_1/deadlock_with_work/main.go:14
↓ 2 callersFunctionoperation
()
lessons/3_lesson_sync_primitives_1/defer_with_mutex/main.go:9
↓ 2 callersFunctionproducer
Need to show solution
lessons/5_lesson_channels/prioritization/main.go:10
↓ 2 callersMethodpromoteLocked
()
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:225
↓ 2 callersMethodpush
(ctx context.Context, commandID int, args []string)
database/internal/database/storage/wal/wal.go:91
↓ 2 callersMethodset
(int32, string, string)
lessons/9_lesson_concurrency_patterns/2pl/transaction.go:9
↓ 2 callersMethodsetLocked
(value *string)
lessons/4_lesson_sync_primitives_2/sync_map_implementation/main.go:57
↓ 2 callersMethodsetNext
(next *node)
lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:32
↓ 2 callersMethodsetNext
(next *node)
lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:33
↓ 2 callersFunctionsubscribe
(name string, data map[string]string, c *sync.Cond)
lessons/4_lesson_sync_primitives_2/cond/main.go:9
↓ 2 callersFunctionsubscriber
(signals chan int)
lessons/5_lesson_channels/broadcast/main.go:12
↓ 2 callersMethodunlock
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:22
↓ 2 callersMethodunlock
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:23
↓ 2 callersMethodwait
(call *call)
lessons/6_lesson_channel_patterns/single_flight/main.go:59
↓ 2 callersFunctionwithLock
(mutex sync.Locker, action func())
lessons/10_lesson_live_coding_practise/cache/main.go:131
↓ 2 callersFunctionwithLock
(mutex sync.Locker, action func())
lessons/4_lesson_sync_primitives_2/rlocker/main.go:5
↓ 2 callersFunctionwithLock
(mutex sync.Locker, action func())
lessons/9_lesson_concurrency_patterns/mvcc/main.go:8
↓ 2 callersFunctionwithLock
(mutex sync.Locker, action func())
lessons/9_lesson_concurrency_patterns/2pl/main.go:8
↓ 2 callersFunctionwork
(result chan int)
additional/lesson_testing_and_profiling/testing_leaks/leak_test.go:12
↓ 1 callersMethodBefore
()
lessons/6_lesson_channel_patterns/barrier/main.go:24
↓ 1 callersFunctionBridge
(in chan chan string)
lessons/6_lesson_channel_patterns/bridge/main.go:7
↓ 1 callersFunctionClientHandler
(c net.Conn)
lessons/2_lesson_gorutines_and_scheduler/tcp_server_without_panic/main.go:26
↓ 1 callersFunctionClientHandler
(c net.Conn)
lessons/2_lesson_gorutines_and_scheduler/tcp_server_with_panic/main.go:27
↓ 1 callersMethodClose
()
database/internal/network/tcp_client.go:57
↓ 1 callersFunctionCreateFile
(filename string)
database/internal/database/filesystem/utils.go:51
↓ 1 callersMethodDel
(context.Context, string)
database/internal/database/database.go:21
↓ 1 callersMethodDel
(ctx context.Context, key string)
database/internal/database/storage/storage.go:106
↓ 1 callersMethodDel
(key string)
database/internal/database/storage/engine/in_memory/hash_table.go:33
↓ 1 callersMethodDelete
(key string)
lessons/8_lesson_sync_algorithms_and_lock_free/sharded_map/main.go:34
↓ 1 callersFunctionDistributedQuery
(addresses []string, query string)
lessons/6_lesson_channel_patterns/moving_later/main.go:18
↓ 1 callersMethodExecute
(Message)
lessons/9_lesson_concurrency_patterns/actors/actor.go:6
↓ 1 callersMethodExistsBetween
(int32, int32, map[string]string)
lessons/9_lesson_concurrency_patterns/mvcc/scheduler.go:12
↓ 1 callersFunctionFetchData1
Need to show solution
lessons/5_lesson_channels/sequential_execution/main.go:10
↓ 1 callersFunctionFetchData2
()
lessons/5_lesson_channels/sequential_execution/main.go:20
↓ 1 callersFunctionFilter
(input <-chan int)
lessons/6_lesson_channel_patterns/filter/main.go:8
↓ 1 callersFunctionGenerateWithClosure
(number int)
lessons/6_lesson_channel_patterns/generator/main.go:5
↓ 1 callersMethodGet
(ctx context.Context, key string)
database/internal/database/storage/storage.go:127
↓ 1 callersMethodGet
(context.Context, string)
lessons/10_lesson_live_coding_practise/cache/main.go:16
↓ 1 callersMethodGet
()
lessons/6_lesson_channel_patterns/future/main.go:25
↓ 1 callersMethodGet
()
lessons/4_lesson_sync_primitives_2/pool/pool_test.go:25
↓ 1 callersMethodGetFuture
()
database/internal/concurrency/promise.go:27
↓ 1 callersMethodGetFuture
()
lessons/6_lesson_channel_patterns/future_with_promise/main.go:44
↓ 1 callersMethodHandleQueries
(ctx context.Context, handler TCPHandler)
database/internal/network/tcp_server.go:59
↓ 1 callersMethodIncrement
(int)
lessons/4_lesson_sync_primitives_2/false_sharing/perf_test.go:17
↓ 1 callersMethodKeys
(context.Context)
lessons/10_lesson_live_coding_practise/cache/main.go:18
↓ 1 callersFunctionLoad
(reader io.Reader)
database/internal/configuration/config.go:51
↓ 1 callersMethodLock
Здесь нет гарантии взаимного исключения (safety), так как несколько горутин могут попасть совместно в критическую секцию
additional/open_lessons/mutex_internals/broken_mutex_2/main.go:21
↓ 1 callersMethodLock
additional/open_lessons/mutex_internals/memory_barriers/main.cpp:14
↓ 1 callersMethodLock
()
additional/open_lessons/mutex_internals/spinlock_with_yield/main.go:19
↓ 1 callersMethodLock
Здесь есть data race и нет гарантии взаимного исключения (safety), так как несколько горутин могут попасть совместно в критическую секцию
additional/open_lessons/mutex_internals/broken_mutex_1/main.go:20
↓ 1 callersMethodLock
()
additional/open_lessons/mutex_internals/ticket_lock/main.go:15
↓ 1 callersMethodLock
()
additional/open_lessons/mutex_internals/spinlock_combined/main.go:21
↓ 1 callersMethodLog
()
database/internal/database/storage/wal/write_request.go:21
↓ 1 callersMethodMGet
(context.Context, []string)
lessons/10_lesson_live_coding_practise/cache/main.go:17
↓ 1 callersFunctionManage
()
additional/lesson_testing_and_profiling/testing_leaks/leak_test.go:17
↓ 1 callersFunctionMergeChannels
(channels ...<-chan int)
lessons/6_lesson_channel_patterns/fan_in/main.go:9
↓ 1 callersFunctionNewBarrier
(size int)
lessons/6_lesson_channel_patterns/barrier/main.go:16
↓ 1 callersFunctionNewErrGroup
()
lessons/6_lesson_channel_patterns/errgroup_implementation/main.go:17
↓ 1 callersFunctionNewFuture
(result <-chan T)
database/internal/concurrency/future.go:9
↓ 1 callersFunctionNewFuture
(task func() interface{})
lessons/6_lesson_channel_patterns/future/main.go:12
↓ 1 callersFunctionNewFuture
(result <-chan interface{})
lessons/6_lesson_channel_patterns/future_with_promise/main.go:12
↓ 1 callersFunctionNewInitializer
(cfg *configuration.Config)
database/internal/initialization/initializer.go:30
↓ 1 callersFunctionNewPersonsPool
()
lessons/4_lesson_sync_primitives_2/pool/pool_test.go:18
↓ 1 callersFunctionNewPromise
(task func() (interface{}, error))
lessons/6_lesson_channel_patterns/promise/main.go:14
↓ 1 callersFunctionNewPromise
()
lessons/6_lesson_channel_patterns/future_with_promise/main.go:27
↓ 1 callersFunctionNewQueue
()
lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/michael_scott_queue/main.go:19
↓ 1 callersFunctionNewQueue
()
lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/queue/main.go:15
↓ 1 callersFunctionNewResponse
(succeed bool, segmentName string, segmentData []byte)
database/internal/database/storage/replication/protocol.go:25
↓ 1 callersFunctionNewSegment
(directory string, maxSegmentSize int)
database/internal/database/filesystem/segment.go:19
↓ 1 callersFunctionNewSemaphore
(ticketsNumber int)
lessons/6_lesson_channel_patterns/semaphore/main.go:13
↓ 1 callersFunctionNewSet
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/without_sync/main.go:14
↓ 1 callersFunctionNewSet
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/optimistic_sync/main.go:40
↓ 1 callersFunctionNewSet
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/lazy_sync/main.go:41
↓ 1 callersFunctionNewSet
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/rough_sync/main.go:18
↓ 1 callersFunctionNewSet
()
lessons/8_lesson_sync_algorithms_and_lock_free/set/fine_sync/main.go:18
↓ 1 callersFunctionNewSingleFlight
()
lessons/6_lesson_channel_patterns/single_flight/main.go:21
↓ 1 callersFunctionNewStack
()
lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/stack/main.go:14
↓ 1 callersFunctionNewStack
()
lessons/8_lesson_sync_algorithms_and_lock_free/lock_free/treiber_stack/main.go:19
↓ 1 callersFunctionNewTCPServer
(address string, logger *zap.Logger, options ...TCPServerOption)
database/internal/network/tcp_server.go:30
↓ 1 callersFunctionNewWorker
()
lessons/6_lesson_channel_patterns/done_channel_with_struct/main.go:13
↓ 1 callersFunctionOrDone
(done chan struct{}, in chan string)
lessons/6_lesson_channel_patterns/or_done/main.go:8
↓ 1 callersFunctionParallelFunction
()
additional/lesson_testing_and_profiling/black_box_testing/main_test.go:8
↓ 1 callersMethodParse
(queryStr string)
database/internal/database/compute/compute.go:30
↓ 1 callersMethodPop
()
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:25
↓ 1 callersFunctionProcess
(value1, value2 int)
lessons/5_lesson_channels/sequential_execution/main.go:30
↓ 1 callersFunctionProcessNumber
(input int, output chan<- int)
additional/lesson_testing_and_profiling/white_box_testing/main_test.go:8
↓ 1 callersMethodPush
(value string)
lessons/3_lesson_sync_primitives_1/sync_stack/main.go:18
↓ 1 callersMethodPut
(person *Person)
lessons/4_lesson_sync_primitives_2/pool/pool_test.go:29
↓ 1 callersFunctionQuery
(string)
lessons/7_lesson_contexts_and_memory_barriers/context_handling/main.go:8
↓ 1 callersMethodQuery
(address string, key string)
lessons/6_lesson_channel_patterns/moving_later/main.go:11
↓ 1 callersMethodReplicationStream
()
database/internal/database/storage/replication/slave.go:91
↓ 1 callersFunctionSegmentLast
(directory string)
database/internal/database/filesystem/utils.go:31
↓ 1 callersMethodSend
([]byte)
database/internal/database/storage/replication/slave.go:18
↓ 1 callersMethodSet
(context.Context, string, string)
database/internal/database/database.go:19
↓ 1 callersMethodSet
(ctx context.Context, key, value string)
database/internal/database/storage/storage.go:85
↓ 1 callersMethodSet
(key, value string)
database/internal/database/storage/engine/in_memory/hash_table.go:18
↓ 1 callersMethodSet
Set don't use with any goroutines
lessons/6_lesson_channel_patterns/future_with_promise/main.go:34
↓ 1 callersFunctionSplitChannel
(inputCh <-chan int, n int)
lessons/6_lesson_channel_patterns/fan_out/main.go:9
↓ 1 callersFunctionTee
(in chan int)
lessons/6_lesson_channel_patterns/tee/main.go:8
← previousnext →201–300 of 875, ranked by callers