Go bytes.Buffer는 스레드로부터 안전한가요?

Question

Go 프로그래밍 언어에서 bytes.Buffer은 스레드로부터 안전합니까? AFAIK, its documentation에는 스레드 안전성에 대한 언급이 없습니다.

Answer 1

번호

의 이동 문서는 간단한 규칙을 다음과 명시 적으로 뭔가에 대한 동시 액세스가 안전하다는 것을 명시되지 않은 경우,이 아니다.

Answer 2

동기 읽기/쓰기를 위해 연결된 객체 (* PipeReader, * PipeWriter) 쌍을 제공하는 io.Pipe() 함수 호출을 사용하십시오. 이 작업은 병렬로 수행 할 수 있으며 스레드로부터 안전합니다.

Answer 3

아니요.하지만 쉽게 스레드 안전 구조로 감쌀 수 있습니다! 간단한 것들에 대한

:

type Buffer struct { 
    b bytes.Buffer 
    m sync.Mutex 
} 
func (b *Buffer) Read(p []byte) (n int, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.Read(p) 
} 
func (b *Buffer) Write(p []byte) (n int, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.Write(p) 
} 
func (b *Buffer) String() string { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.String() 
} 

.. 그리고 그것은 평소 var buf Buffer으로 사용 등

bytes.Buffer의 이상을 원하십니까? 체리 선택에 자유롭게 느끼십시오 :

func (b *Buffer) Bytes() []byte { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.Bytes() 
} 
func (b *Buffer) Cap() int { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.Cap() 
} 
func (b *Buffer) Grow(n int) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    b.b.Grow(n) 
} 
func (b *Buffer) Len() int { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.Len() 
} 
func (b *Buffer) Next(n int) []byte { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.Next(n) 
} 
func (b *Buffer) ReadByte() (c byte, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.ReadByte() 
} 
func (b *Buffer) ReadBytes(delim byte) (line []byte, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.ReadBytes(delim) 
} 
func (b *Buffer) ReadFrom(r io.Reader) (n int64, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.ReadFrom(r) 
} 
func (b *Buffer) ReadRune() (r rune, size int, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.ReadRune() 
} 
func (b *Buffer) ReadString(delim byte) (line string, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.ReadString(delim) 
} 
func (b *Buffer) Reset() { 
    b.m.Lock() 
    defer b.m.Unlock() 
    b.b.Reset() 
} 
func (b *Buffer) Truncate(n int) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    b.b.Truncate(n) 
} 
func (b *Buffer) UnreadByte() error { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.UnreadByte() 
} 
func (b *Buffer) UnreadRune() error { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.UnreadRune() 
} 
func (b *Buffer) WriteByte(c byte) error { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.WriteByte(c) 
} 
func (b *Buffer) WriteRune(r rune) (n int, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.WriteRune(r) 
} 
func (b *Buffer) WriteString(s string) (n int, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.WriteString(s) 
} 
func (b *Buffer) WriteTo(w io.Writer) (n int64, err error) { 
    b.m.Lock() 
    defer b.m.Unlock() 
    return b.b.WriteTo(w) 
}