Go并发场景下如何解决导入包日志输出交错问题？

针对你遇到的问题——自己的并发函数日志已通过锁或通道同步，但导入的第三方包函数日志仍交错混乱，可尝试以下几种实用方案：

1. 替换第三方包的日志输出为同步Writer #

如果第三方包使用标准库log或支持自定义输出目标，你可以为其日志输出添加同步锁，确保每条日志完整输出：

import (
    "io"
    "log"
    "sync"
    thirdparty "path/to/third/package"
)

// 定义带锁的Writer
type lockedWriter struct {
    writer io.Writer
    mu     *sync.Mutex
}

func (lw *lockedWriter) Write(p []byte) (n int, err error) {
    lw.mu.Lock()
    defer lw.mu.Unlock()
    return lw.writer.Write(p)
}

// 在init中替换第三方包的日志输出
func init() {
    var mu sync.Mutex
    // 如果第三方包用的是全局log实例，替换其输出
    originalOut := log.Writer()
    log.SetOutput(&lockedWriter{writer: originalOut, mu: &mu})

    // 若第三方包有自定义日志实例，调用其提供的输出设置方法（如SetOutput）
    // thirdparty.CustomLog.SetOutput(&lockedWriter{writer: originalOut, mu: &mu})
}

2. 串行化第三方函数的调用 #

如果第三方包的日志混乱是因为多goroutine同时执行函数2导致的，直接在调用函数2时加全局锁，确保同一时间只有一个goroutine执行该函数：

import (
    "sync"
    thirdparty "path/to/third/package"
)

var func2SyncMutex sync.Mutex

// 在你的goroutine任务中调用函数2
func workerTask() {
    // ... 你的业务代码

    func2SyncMutex.Lock()
    thirdparty.Func2() // 加锁后，该函数的所有日志操作都会串行执行
    func2SyncMutex.Unlock()

    // ... 后续业务代码
}

3. 统一进程内的日志流转 #

如果你的项目已经实现了基于通道的日志处理系统，可以将第三方包的日志也导向这个通道。比如替换标准输出/错误输出为自定义的通道Writer：

import (
    "io"
    "os"
    thirdparty "path/to/third/package"
)

// 假设你已有的日志通道
var logChan chan []byte

// 自定义Writer，将输出写入日志通道
type chanWriter struct{}

func (cw chanWriter) Write(p []byte) (n int, err error) {
    logChan <- p
    return len(p), nil
}

// 初始化时替换输出
func init() {
    // 替换标准输出和错误输出，影响所有使用os.Stdout/err的日志
    // 注意：此方法会影响整个进程的输出，需谨慎使用
    os.Stdout = chanWriter{}
    os.Stderr = chanWriter{}
}

4. 修改第三方包的日志实现（终极方案） #

如果以上方法都不适用，且你有代码修改权限，可以直接在第三方包的日志输出逻辑中添加同步锁，或者将其日志替换为已同步的日志库（如zap、logrus等自带并发安全的库）。

内容的提问来源于stack exchange，提问作者hitzoglin