diff --git a/decor/eta.go b/decor/eta.go
index cbe657f..6ee0f7d 100644
--- a/decor/eta.go
+++ b/decor/eta.go
@@ -39,7 +39,7 @@
 	} else {
 		average = ewma.NewMovingAverage(age)
 	}
-	return MovingAverageETA(style, average, nil, wcc...)
+	return MovingAverageETA(style, NewThreadSafeMovingAverage(average), nil, wcc...)
 }
 
 // MovingAverageETA decorator relies on MovingAverage implementation to calculate its average.
diff --git a/decor/moving_average.go b/decor/moving_average.go
index 165ef1e..a1be8ad 100644
--- a/decor/moving_average.go
+++ b/decor/moving_average.go
@@ -70,5 +70,5 @@
 
 // NewMedian is fixed last 3 samples median MovingAverage.
 func NewMedian() ewma.MovingAverage {
-	return new(medianWindow)
+	return NewThreadSafeMovingAverage(new(medianWindow))
 }
diff --git a/decor/speed.go b/decor/speed.go
index 50415fd..54bafd5 100644
--- a/decor/speed.go
+++ b/decor/speed.go
@@ -46,7 +46,7 @@
 	} else {
 		average = ewma.NewMovingAverage(age)
 	}
-	return MovingAverageSpeed(unit, format, average, wcc...)
+	return MovingAverageSpeed(unit, format, NewThreadSafeMovingAverage(average), wcc...)
 }
 
 // MovingAverageSpeed decorator relies on MovingAverage implementation