chore: partial done flow

nathanverse · nathanverse · commit 580530bb6e59 · 2025-12-08T08:42:31.000+07:00
diff --git a/0-limit-crawler/check_test.go b/0-limit-crawler/check_test.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
diff --git a/0-limit-crawler/mockfetcher.go b/0-limit-crawler/mockfetcher.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
diff --git a/1-producer-consumer/mockstream.go b/1-producer-consumer/mockstream.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
diff --git a/2-race-in-cache/check_test.go b/2-race-in-cache/check_test.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
@@ -39,7 +39,7 @@ func TestLRU(t *testing.T) {
 		wg.Add(1)
 		go func(i int) {
 			value := cache.Get("Test" + strconv.Itoa(i))
-			if value != "Test" + strconv.Itoa(i) {
+			if value != "Test"+strconv.Itoa(i) {
 				t.Errorf("Incorrect db response %v", value)
 			}
 			wg.Done()
diff --git a/2-race-in-cache/mockdb.go b/2-race-in-cache/mockdb.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
@@ -12,7 +12,7 @@ import (
 )
 
 // MockDB used to simulate a database model
-type MockDB struct{
+type MockDB struct {
 	Calls int32
 }
 
diff --git a/2-race-in-cache/mockserver.go b/2-race-in-cache/mockserver.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
@@ -31,7 +31,7 @@ func RunMockServer(cache *KeyStoreCache, t *testing.T) {
 				go func(i int) {
 					value := cache.Get("Test" + strconv.Itoa(i))
 					if t != nil {
-						if value != "Test" + strconv.Itoa(i) {
+						if value != "Test"+strconv.Itoa(i) {
 							t.Errorf("Incorrect db response %v", value)
 						}
 					}
diff --git a/3-limit-service-time/mockserver.go b/3-limit-service-time/mockserver.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
diff --git a/4-graceful-sigint/mockprocess.go b/4-graceful-sigint/mockprocess.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
@@ -15,7 +15,7 @@ import (
 
 // MockProcess for example
 type MockProcess struct {
-	mu sync.Mutex
+	mu        sync.Mutex
 	isRunning bool
 }
 
diff --git a/5-session-cleaner/helper.go b/5-session-cleaner/helper.go
@@ -1,7 +1,7 @@
 //////////////////////////////////////////////////////////////////////
 //
 // DO NOT EDIT THIS PART
-// Your task is to edit `main.go`
+// Your task is to edit `base.go`
 //
 
 package main
diff --git a/6-cancellation/cancellation/imp/query_operation.go b/6-cancellation/cancellation/imp/query_operation.go
@@ -38,7 +38,7 @@ func (op *mockQueryOperation) run(ctx context.Context) {
 	// Simulate query execution time
 	queryDuration := 3 * time.Second // Default query duration
 	if op.query == "FAST QUERY" {
-		queryDuration = 500 * time.Millisecond // A faster query
+		queryDuration = 500 * time.Millisecond // Iteration faster query
 	}
 
 	log.Printf("Mock QueryOperation: Starting execution for '%s' (will take %v)", op.query, queryDuration)
diff --git a/7-lfu-cache/load_group.go b/7-lfu-cache/load_group.go
@@ -0,0 +1,71 @@
+package main
+
+import (
+	"container/list"
+	"sync"
+)
+
+type LoadGroup struct {
+	calls map[string]*call
+	mutex sync.Mutex
+	cache *Cache
+}
+
+type call struct {
+	mu     sync.RWMutex
+	result *string
+	err    *error
+}
+
+// Get ensures one loading task is run even if multiple threads are waiting on the same key
+// /*
+func (l *LoadGroup) Get(key string, loaderFunc LoaderFunc) (string, error) {
+	l.mutex.Lock()
+	cache := *(l.cache)
+	vc, err := cache.GetWithoutLoad(key)
+	if err != nil {
+		//
+	}
+
+	if len(vc) != 0 {
+		l.mutex.Unlock()
+		return vc, nil
+	}
+
+	if call, ok := l.calls[key]; ok {
+		l.mutex.Unlock()
+
+		call.mu.RLock()
+		result := call.result
+		call.mu.RUnlock()
+		return *result, nil
+	}
+
+	call := &call{
+		result: new(string),
+	}
+
+	l.calls[key] = call
+	call.mu.Lock()
+	l.mutex.Unlock()
+
+	// TODO: handling panic
+	v, err := loaderFunc(key)
+	if err != nil {
+
+	}
+	call.result = &v
+	call.mu.Unlock()
+
+	// Remove call and update cache
+	l.mutex.Lock()
+	err = cache.Set(key, v)
+	if err != nil {
+		// TODO: handling error
+		l.mutex.Unlock()
+		return "", err
+	}
+
+	delete(l.calls, key)
+	l.mutex.Unlock()
+}
diff --git a/7-lfu-cache/main.go b/7-lfu-cache/main.go
@@ -10,6 +10,7 @@ var EMPTY_ERROR = errors.New("EMPTY ERROR")
 
 type Cache interface {
 	Get(key string) (string, error)
+	GetWithoutLoad(key string) (string, error)
 	Set(key, value string) error
 }
 
@@ -41,9 +42,6 @@ type lfuItem struct {
 	el    *list.Element // Reference to lruEntry
 }
 
-type LoadGroup struct {
-}
-
 func NewLFUCache(size int, loaderFunc LoaderFunc) (*LFUCache, error) {
 	if size <= 0 {
 		return nil, errors.New("size must be greater than zero")
@@ -99,6 +97,10 @@ func (cache *LFUCache) Get(key string) (string, error) {
 	return value, nil
 }
 
+func load(key string) (string, error) {
+
+}
+
 func (cache *LFUCache) GetKeys() []string {
 	keys := make([]string, 0)
 	for k, _ := range cache.cache {
diff --git a/go.mod b/go.mod
@@ -1,3 +1,10 @@
 module github.com/nathanverse/go-concurrency-exercises
 
 go 1.24.2
+
+require github.com/pkg/profile v1.7.0
+
+require (
+	github.com/felixge/fgprof v0.9.3 // indirect
+	github.com/google/pprof v0.0.0-20211214055906-6f57359322fd // indirect
+)
diff --git a/go.sum b/go.sum
@@ -0,0 +1,25 @@
+github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
+github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
+github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/felixge/fgprof v0.9.3 h1:VvyZxILNuCiUCSXtPtYmmtGvb65nqXh2QFWc0Wpf2/g=
+github.com/felixge/fgprof v0.9.3/go.mod h1:RdbpDgzqYVh/T9fPELJyV7EYJuHB55UTEULNun8eiPw=
+github.com/google/pprof v0.0.0-20211214055906-6f57359322fd h1:1FjCyPC+syAzJ5/2S8fqdZK1R22vvA0J7JZKcuOIQ7Y=
+github.com/google/pprof v0.0.0-20211214055906-6f57359322fd/go.mod h1:KgnwoLYCZ8IQu3XUZ8Nc/bM9CCZFOyjUNOSygVozoDg=
+github.com/ianlancetaylor/demangle v0.0.0-20210905161508-09a460cdf81d/go.mod h1:aYm2/VgdVmcIU8iMfdMvDMsRAQjcfZSKFby6HOFvi/w=
+github.com/pkg/profile v1.7.0 h1:hnbDkaNWPCLMO9wGLdBFTIZvzDrDfBM2072E1S9gJkA=
+github.com/pkg/profile v1.7.0/go.mod h1:8Uer0jas47ZQMJ7VD+OHknK4YDY07LPUC6dEvqDjvNo=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
diff --git a/playground/main.go b/playground/main.go
@@ -1,45 +1,5 @@
 package main
 
-import (
-	"context"
-	"errors"
-	"fmt"
-	"time"
-
-	"golang.org/x/sync/errgroup"
-)
-
-func hello() error { // hello needs to return error to be compatible with errgroup.Go
-	fmt.Println("hello world")
-	time.Sleep(time.Second * 10)
-	fmt.Println("hello world ended")
-	return nil // Return nil or an actual error
-}
-
-func hello1() error {
-	fmt.Println("hello world 1")
-	time.Sleep(time.Second * 1)
-	return errors.New("hello world 1 goes wrong")
-}
-
 func main() {
-	g, cancel := errgroup.WithContext(context.Background())
-	g.SetLimit(2) // Set a limit of 2 concurrent goroutines
-
-	// Pass the functions as values, not the result of their execution
-	g.Go(hello)  // Correct way: pass the function hello
-	g.Go(hello1) // Correct way: pass the function hello1
-
-	select {
-	case <-cancel.Done():
-		{
-			err := cancel.Err()
-			if err != nil {
-				fmt.Printf("Error occurred %s", err.Error())
-			}
-		}
-	}
 
-	_ := g.Wait()
-	fmt.Println("Done")
 }
diff --git a/queue/cmd/bench/main.go b/queue/cmd/bench/main.go
@@ -0,0 +1,28 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"os"
+
+	"github.com/nathanverse/go-concurrency-exercises/queue/runner"
+)
+
+func main() {
+	addr := flag.String("addr", ":8080", "queue server address")
+	total := flag.Int("total", 1000, "total tasks to run")
+	concurrency := flag.Int("concurrency", 8, "concurrent client workers")
+	iterations := flag.Int("iterations", 100000, "hash iterations per task")
+	flag.Parse()
+
+	err := runner.RunClient(runner.ClientConfig{
+		Addr:        *addr,
+		Total:       *total,
+		Concurrency: *concurrency,
+		Iterations:  *iterations,
+	})
+	if err != nil {
+		fmt.Fprintln(os.Stderr, err)
+		os.Exit(1)
+	}
+}
diff --git a/queue/go.mod b/queue/go.mod
@@ -0,0 +1,10 @@
+module github.com/nathanverse/go-concurrency-exercises/queue
+
+go 1.21
+
+require github.com/pkg/profile v1.7.0
+
+require (
+	github.com/felixge/fgprof v0.9.3 // indirect
+	github.com/google/pprof v0.0.0-20211214055906-6f57359322fd // indirect
+)
diff --git a/queue/go.sum b/queue/go.sum
@@ -0,0 +1,25 @@
+github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
+github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
+github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/felixge/fgprof v0.9.3 h1:VvyZxILNuCiUCSXtPtYmmtGvb65nqXh2QFWc0Wpf2/g=
+github.com/felixge/fgprof v0.9.3/go.mod h1:RdbpDgzqYVh/T9fPELJyV7EYJuHB55UTEULNun8eiPw=
+github.com/google/pprof v0.0.0-20211214055906-6f57359322fd h1:1FjCyPC+syAzJ5/2S8fqdZK1R22vvA0J7JZKcuOIQ7Y=
+github.com/google/pprof v0.0.0-20211214055906-6f57359322fd/go.mod h1:KgnwoLYCZ8IQu3XUZ8Nc/bM9CCZFOyjUNOSygVozoDg=
+github.com/ianlancetaylor/demangle v0.0.0-20210905161508-09a460cdf81d/go.mod h1:aYm2/VgdVmcIU8iMfdMvDMsRAQjcfZSKFby6HOFvi/w=
+github.com/pkg/profile v1.7.0 h1:hnbDkaNWPCLMO9wGLdBFTIZvzDrDfBM2072E1S9gJkA=
+github.com/pkg/profile v1.7.0/go.mod h1:8Uer0jas47ZQMJ7VD+OHknK4YDY07LPUC6dEvqDjvNo=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
diff --git a/queue/internal/base.go b/queue/internal/base.go
diff --git a/queue/main.go b/queue/main.go
diff --git a/queue/runner/client.go b/queue/runner/client.go
diff --git a/queue/runner/server.go b/queue/runner/server.go
diff --git a/queue/server/server.go b/queue/server/server.go
diff --git a/queue/tasks/base.go b/queue/tasks/base.go

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`//////////////////////////////////////////////////////////////////////`
`2`	`2`	`//`
`3`	`3`	`// DO NOT EDIT THIS PART`
`4`		-// Your task is to edit `main.go`
	`4`	+// Your task is to edit `base.go`
`5`	`5`	`//`
`6`	`6`
`7`	`7`	`package main`
`@@ -12,7 +12,7 @@ import (`
`12`	`12`	`)`
`13`	`13`
`14`	`14`	`// MockDB used to simulate a database model`
`15`		`-type MockDB struct{`
	`15`	`+type MockDB struct {`
`16`	`16`	`Calls int32`
`17`	`17`	`}`
`18`	`18`
Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ func (op *mockQueryOperation) run(ctx context.Context) {`
`38`	`38`	`// Simulate query execution time`
`39`	`39`	`queryDuration := 3 * time.Second // Default query duration`
`40`	`40`	`if op.query == "FAST QUERY" {`
`41`		`- queryDuration = 500 * time.Millisecond // A faster query`
	`41`	`+ queryDuration = 500 * time.Millisecond // Iteration faster query`
`42`	`42`	`}`
`43`	`43`
`44`	`44`	`log.Printf("Mock QueryOperation: Starting execution for '%s' (will take %v)", op.query, queryDuration)`