请教一个并发设计问题

var fmutex = sync.Mutex{}
var A = make(chan string, 1048576)
var B  = make([]flowStatistic,0)

func foo(){
	go getData()
	go txData()
	go handleData()
}

//接受数据
func getData(){
	for {
		...
		data := conn.Read()
		A<-data
	}
}

func txData(){
	for{
		var fs flowStatistic
		err := json.Unmarshal([]byte(<-A), &fs) //这里不断解析A传过来的数据
		...
		B = append(B,fs)			//仅仅在这里会插入B
	}
}

func handleData(){
	//这里每5秒钟对B中的数据进行聚合并入库，耗时较多。为了不丢数据，我锁住B，处理完后清空B中数据并解锁
	for{
		time.Sleep(5 * time.Second)
		fmutex.Lock()
		...
		B = make([]flowStatistic,0)
		fmutex.Unlock()
	}
}

有老哥提到了append B的时候应该锁住，我试了下发现实际上还是会丢数据。

var fmutex = sync.Mutex{}
var A = make(chan string, 1048576)
var B  = make([]flowStatistic,0)

func foo(){
	go getData()
	go txData()
	go handleData()
}

//接受数据
func getData(){
	for {
		...
                addr, err := net.ResolveUnixAddr("unixgram", sock)
	        conn, err := net.ListenUnixgram("unixgram", addr)
		data := conn.ReadFromUnix()
		A<-data
	}
}

func txData(){
	for{
		var fs flowStatistic
		err := json.Unmarshal([]byte(<-A), &fs) //这里不断解析A传过来的数据
		...
                fmutex.Lock()
		B = append(B,fs)			
                fmutex.Unlock()
	}
}

func handleData(){
	//这里每5秒钟对B中的数据进行聚合并入库，耗时较多。为了不丢数据，我锁住B，处理完后清空B中数据并解锁
	for{
		time.Sleep(5 * time.Second)
		fmutex.Lock()
		...
		B = make([]flowStatistic,0)
		fmutex.Unlock()
	}
}

改进了一下