使用Golang并发遍历源和目标目录，通过walkDir函数将文件路径发送至channel，实现高效路径收集与元信息获取。

构建一个并发文件同步工具需要处理多个核心问题：文件遍历、内容比对、增量更新、以及在多 goroutine 环境下的读写安全。Golang 的并发模型和同步机制为此类任务提供了简洁高效的解决方案。下面通过实战方式讲解如何使用 Golang 实现一个基础但实用的并发文件同步工具。

1. 并发文件遍历与路径收集

文件同步的第一步是扫描源目录和目标目录，获取所有文件路径及其元信息（如修改时间、大小）。为了提升效率，可使用 goroutine 并发遍历目录树。

利用 walk 函数配合 channel 将发现的文件路径发送到管道中，由后续流程消费：

func walkDir(root string, fileCh chan<- string) {
    filepath.Walk(root, func(path string, info os.FileInfo, err error) error {
        if err != nil {
            return nil // 忽略无法访问的文件
        }
        if !info.IsDir() {
            fileCh <- path
        }
        return nil
    })
    close(fileCh)
}

启动多个 worker 处理文件列表时，可通过缓冲 channel 控制并发数，避免系统资源耗尽。

2. 文件内容比对与差异检测

同步前需判断哪些文件需要更新。常见策略是比较修改时间和文件大小，更精确的方式是计算哈希值（如 MD5 或 SHA256）。

为避免阻塞主线程，哈希计算可在独立 goroutine 中完成：

func hashFile(path string) (string, error) {
    f, err := os.Open(path)
    if err != nil {
        return "", err
    }
    defer f.Close()
h := sha256.New()
_, err = io.Copy(h, f)
return fmt.Sprintf("%x", h.Sum(nil)), err
}
将待同步文件分批送入工作池，每个 worker 计算源文件与目标文件的哈希是否一致，仅当不一致时触发复制操作。
3. 使用 sync.Mutex 保护共享状态
在并发环境下，多个 goroutine 可能同时尝试记录日志、更新进度或写入状态变量。这类共享资源必须加锁保护。
例如维护一个同步计数器：
var (
    mu sync.Mutex
    copiedCount int
)
func incCopied() {
mu.Lock()
defer mu.Unlock()
copiedCount++
}
也可使用 sync.Atomic 操作替代锁，提高性能：
atomic.AddInt32(&copiedCount, 1)
4. 控制并发度：带缓冲的工作池
盲目开启大量 goroutine 会导致系统负载过高。推荐使用固定数量的 worker 从任务 channel 消费任务，实现可控并发。
示例代码：
func startWorkers(tasks <-chan FileTask, workers int) {
    var wg sync.WaitGroup
    for i := 0; i < workers; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            for task := range tasks {
                task.Process()
            }
        }()
    }
    wg.Wait()
}
主流程将差异文件构造成任务放入 channel，worker 自动拉取并执行复制逻辑。
基本上就这些。通过合理使用 channel 进行数据传递、用 mutex 或 atomic 保证状态一致性，并控制并发规模，就能构建出稳定高效的文件同步工具。实际项目中还可加入错误重试、断点续传、实时监控等功能进一步增强健壮性。