Merge pull request #11 from go-zoox/feat/context-add-create-concurren…

…cy-method

feat: context add create concurrency method

context.go

@@ -33,6 +33,7 @@ import (
 	"github.com/go-zoox/zoox/components/context/user"
 	"github.com/go-zoox/zoox/utils"
 
+	"github.com/go-zoox/concurrency"
 	"github.com/go-zoox/cookie"
 	"github.com/go-zoox/core-utils/safe"
 	"github.com/go-zoox/fetch"
@@ -922,3 +923,8 @@ func (ctx *Context) Publish(msg *pubsub.Message) error {
 func (ctx *Context) Subscribe(topic string, handler pubsub.Handler) error {
 	return ctx.App.PubSub().Subscribe(ctx.Context(), topic, handler)
 }
+
+// Concurrency creates a concurrency.
+func (ctx *Context) Concurrency(limit int) *concurrency.Concurrency {
+	return concurrency.New(limit)
+}

go.mod

@@ -4,6 +4,7 @@ go 1.20
 
 require (
 	github.com/go-zoox/cache v1.0.3
+	github.com/go-zoox/concurrency v1.2.0
 	github.com/go-zoox/cookie v1.2.0
 	github.com/go-zoox/core-utils v1.2.13
 	github.com/go-zoox/counter v1.2.0

go.sum

@@ -37,6 +37,8 @@ github.com/go-zoox/chalk v1.0.2 h1:DCWft37fogmvqF37JdbGSLg28L/tQeA8u0lMvb62KOg=
 github.com/go-zoox/chalk v1.0.2/go.mod h1:z5+qvE9nEJI5uT4px2tyoFa/xxkqf3CUo22KmXLKbNI=
 github.com/go-zoox/compress v1.0.1 h1:EyNxo5NscMLua5fvUdiGSF+BwhuTfMeyppu7OwKAW7Q=
 github.com/go-zoox/compress v1.0.1/go.mod h1:iV6CcNulf3OuEfA1h1VOsaBqYH81cVSg5wNi5HDx2h4=
+github.com/go-zoox/concurrency v1.2.0 h1:iucwSWQ0Y9fFIG+eZvyHjMrIPSnaKJTGfOcGbIx91yg=
+github.com/go-zoox/concurrency v1.2.0/go.mod h1:rghauUPHEDp8HJzaVlU851HWqiAqD8lUVp45K/dtNvw=
 github.com/go-zoox/cookie v1.2.0 h1:MO33lPQ/QGJIAEzgrsAfEpJc25lcJ/XR0w+smM19sNQ=
 github.com/go-zoox/cookie v1.2.0/go.mod h1:+xEawxty0L+z+4EIvTF2AaHUkUM7oIecGZ9XrEaYqsI=
 github.com/go-zoox/core-utils v1.0.4/go.mod h1:EknM3KLL6/kagL95wZbWE7mRRcYCG/fHqiJ/EH0ihAs=