diff --git a/gturbine/gtshred/shred_group.go b/gturbine/gtshred/shred_group.go
index 550df90..c062acc 100644
--- a/gturbine/gtshred/shred_group.go
+++ b/gturbine/gtshred/shred_group.go
@@ -236,6 +236,9 @@ func (g *ShredGroup) CollectShred(shred *gturbine.Shred) (bool, error) {
 
 // Reset clears the ShredGroup data while maintaining allocated memory
 func (g *ShredGroup) Reset() {
+	g.mu.Lock()
+	defer g.mu.Unlock()
+
 	g.GroupID = uuid.New().String()
 	g.BlockHash = g.BlockHash[:0]
 	g.Height = 0