电脑上网监控软件中的滑动窗口算法及Go语言实现

package main
import (
        "fmt"
        "sync"
        "time"
)
// Slidi上网监控软件的流量统计需求
type SlidingWindow struct {
        win int           // 窗口大小，单位：秒
        sampleRate time.Dura 采样周期，单位：秒
        data       []int64     窗口内各采样周期的数据包大小（单位：字节）
        mu      .Mutex    // 互斥锁，保证并发安全
}
// NewSlidingWindow 初始化滑动窗口
func NewSlidingWindow(windowSize int, sampleRate time.Duration) *SlidingWindow {
        return &SlidingWindow{
                windowampleRate: sampleRate,
                data:       make([]int64, 0,        }
}
// AddData 向窗口中添加新的采样数据（电脑上网数据包大小）
func (sw *SlidingWindow) AddData(packetSize int64) {
        sw.mu.Lock()
        defer sw.mu.Unlock()
旧的数据（头部数据）
        if len(sw.data) == sw.windo
                sw.data = sw.data[1:]
        }
        // 添sw.data, packetSize)
}
// CalculateTotalFlow 计算当前窗口内的总流量（适配电脑上网监控软件流量统计需求）
func (sw *SlidingWindow) CalculateTotalFlow() int64 {
        sw.mu.Lock()
    u.Unlock()
        var total int64
        for _, size := range sw.dat size
        }
        return total
}
// 测试例程：模拟与流量统计过程
func main() {
        // 初始化大小10秒，采样周期1秒
        window := NewSlidingWindow(10, time.
        // 模拟并发采集数据包（电脑上网监控软捕获场景）
        var wg sync.WaitGroup
        < 3; i++ {
                wg.Add(1)
                go func(threadID int) {
    ; j < 15; j++ {
                                // 模拟捕获的数据包大小（100-1000字节随机）
                                packe)
                                fmt.Printf("ID, packetSize)
                                // 按采样周期休眠
                              }
              总流量
        go func() {
                ticker := time.NewTic                defer ticker.Stop()
                for range ticker.C {
    TotalFlow()
                        fmt.P%.2fKB\n", totalFlow, float64(totalFlow)/1024)
                }
       .Println("数据包采集完成，滑动窗口统计结束")
} }()
        wg.Wait()
        fmtrintf("当前窗口总流量：%d字节，即                    totalFlow := window.Calculateker(2 * time.Second)
  }(i)
        }
        // 启动统计协程：每2秒输出一次当前窗口内的                          time.Sleep(window.sampleRate)
线程%d：捕获数据包，大小%d字节\n", threadtSize := int64(100 + j*60)
                                window.AddData(packetSize                    defer wg.Done()
                        for j := 0for i := 0; i 件的多协程数据Second)滑动窗口：窗口电脑上网监控软件的数据包采集a {
                total +=    defer sw.m加新数据到窗口尾部
        sw.data = append(wSize {
        // 若窗口已满，移除最监控软件捕获的 windowSize),
Size: windowSize,
                s   sync  // 存储tion //dowSizengWindow 滑动窗口结构体，适配电脑