README
¶
Go-LOCK
- 用法
package main
import (
"fmt"
golock "github.com/gif-gif/go.io/go-lock"
gopool "github.com/gif-gif/go.io/go-pool"
"github.com/gif-gif/go.io/goio"
)
func main() {
goio.Init(goio.DEVELOPMENT)
testGoPool()
//testSyncLock()
}
func testGoPool() {
var (
count int
)
lock := golock.New()
//并发池
gp := gopool.NewFixedSizePool(10, 10)
defer gp.StopAndWait()
group := gp.NewTaskGroup()
for i := 0; i < 10; i++ {
group.Submit(func() {
for i := 1000; i > 0; i-- {
lock.WLockFunc(func(parameters ...any) {
count++
})
}
fmt.Println(count)
})
}
group.Wait()
}
func testSyncLock() {
var (
count int
)
lock := golock.New()
for i := 0; i < 2; i++ {
go func() {
for i := 1000; i > 0; i-- {
//lock.WLock()
//count++
//lock.WUnlock()
lock.WLockFunc(func(parameters ...any) {
count++
})
}
fmt.Println(count)
}()
}
fmt.Scanf("\n") //等待子线程全部结束
}
Documentation
¶
Index ¶
- type GoLock
- func (g *GoLock) Lock()
- func (g *GoLock) LockFunc(fn func(parameters ...any), parameters ...any)
- func (g *GoLock) RLock()
- func (g *GoLock) RLockFunc(fn func(parameters ...any), parameters ...any)
- func (g *GoLock) RUnlock()
- func (g *GoLock) Unlock()
- func (g *GoLock) WLock()
- func (g *GoLock) WLockFunc(fn func(parameters ...any), parameters ...any)
- func (g *GoLock) WUnlock()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GoLock ¶
type GoLock struct {
Mutex sync.Mutex // 读锁时不能写，写锁时不能读取
MuteRW sync.RWMutex //读写互斥锁，并发读取，单一写入。读多写少性能会好
}
RWMutex 也称为读写互斥锁，读写互斥锁就是读取/写入互相排斥的锁。它可以由任意数量的读取操作的 goroutine 或单个写入操作的 goroutine 持有。 读写互斥锁 RWMutex 类型有五个方法，Lock，Unlock，Rlock，RUnlock 和 RLocker。其中，RLocker 返回一个 Locker 接口， 该接口通过调用 rw.RLock 和 rw.RUnlock 来实现 Lock 和 Unlock 方法。 不能拷贝锁
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.