zhangdeman/json_filter
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

所有操作加锁

Browse Source
This commit is contained in:
白茶清欢 2025-05-06 16:02:14 +08:00
parent 691bee91a5
commit 777a5cb93c
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
implement/sjson_write.go
View File

@ -32,6 +32,8 @@ func (s *SjsonWrite) Delete(dataPath string) error {
var ( var (
err error err error
) )
s.l.Lock()
defer s.l.Unlock()
if s.res, err = sjson.Delete(s.res, dataPath); nil != err { if s.res, err = sjson.Delete(s.res, dataPath); nil != err {
return err return err
} }
@ -90,6 +92,8 @@ func (s *SjsonWrite) Set(dataPath string, data any) error {
} }
func (s *SjsonWrite) Result() string { func (s *SjsonWrite) Result() string {
s.l.RLock()
defer s.l.RUnlock()
return s.res return s.res
} }
@ -105,7 +109,7 @@ func (s *SjsonWrite) Map() (map[string]any, error) {
} }
func (s *SjsonWrite) MapWithReceiver(receiver any) error { func (s *SjsonWrite) MapWithReceiver(receiver any) error {
return serialize.JSON.UnmarshalWithNumberForString(s.res, receiver) return serialize.JSON.UnmarshalWithNumberForString(s.Result(), receiver)
} }
func (s *SjsonWrite) Array() ([]any, error) { func (s *SjsonWrite) Array() ([]any, error) {
@ -120,5 +124,5 @@ func (s *SjsonWrite) Array() ([]any, error) {
} }
func (s *SjsonWrite) ArrayWithReceiver(receiver any) error { func (s *SjsonWrite) ArrayWithReceiver(receiver any) error {
return serialize.JSON.UnmarshalWithNumberForString(s.res, receiver) return serialize.JSON.UnmarshalWithNumberForString(s.Result(), receiver)
} }