package/go_process_manager
1
0
Fork 0
mirror of https://github.com/lzh-1625/go_process_manager.git synced 2025-10-05 16:06:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

delete unused lock

Browse Source
This commit is contained in:
akrike
2025-02-08 01:08:33 +08:00
parent 383f5691fb
commit 8ff891a5a1
1 changed files with 0 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
internal/app/api/ws.go
View File

@@ -2,7 +2,6 @@ package api
import ( import (
"context" "context"
"sync"
"time" "time"
"github.com/lzh-1625/go_process_manager/internal/app/constants" "github.com/lzh-1625/go_process_manager/internal/app/constants"
@@ -21,20 +20,15 @@ var WsApi = new(wsApi)
type WsConnetInstance struct { type WsConnetInstance struct {
WsConnect *websocket.Conn WsConnect *websocket.Conn
WsMux sync.Mutex
CancelFunc context.CancelFunc CancelFunc context.CancelFunc
} }
func (w *WsConnetInstance) Write(b []byte) { func (w *WsConnetInstance) Write(b []byte) {
w.WsMux.Lock()
w.WsConnect.WriteMessage(websocket.BinaryMessage, b) w.WsConnect.WriteMessage(websocket.BinaryMessage, b)
w.WsMux.Unlock()
} }
func (w *WsConnetInstance) WriteString(s string) { func (w *WsConnetInstance) WriteString(s string) {
w.WsMux.Lock()
w.WsConnect.WriteMessage(websocket.TextMessage, []byte(s)) w.WsConnect.WriteMessage(websocket.TextMessage, []byte(s))
w.WsMux.Unlock()
} }
func (w *WsConnetInstance) Cancel() { func (w *WsConnetInstance) Cancel() {
w.CancelFunc() w.CancelFunc()
@@ -66,7 +60,6 @@ func (w *wsApi) WebsocketHandle(ctx *gin.Context) {
wsCtx, cancel := context.WithCancel(context.Background()) wsCtx, cancel := context.WithCancel(context.Background())
wci := &WsConnetInstance{ wci := &WsConnetInstance{
WsConnect: conn, WsConnect: conn,
WsMux: sync.Mutex{},
CancelFunc: cancel, CancelFunc: cancel,
} }
proc.ReadCache(wci) proc.ReadCache(wci)