Fix randomness for threading

monai/transforms/compose.py

@@ -106,8 +106,12 @@ def execute_compose(
         return data
 
     for _transform in transforms[start:end]:
-        if threading:
-            _transform = deepcopy(_transform) if isinstance(_transform, ThreadUnsafe) else _transform
+        if threading and isinstance(_transform, ThreadUnsafe):
+            if isinstance(_transform, Randomizable):
+                # iterate the random state before deepcopy, otherwise there is no randomness
+                d = dict(data) if isinstance(data, Mapping) else data
+                _transform.randomize(d)
+            _transform = deepcopy(_transform)
         data = apply_transform(
             _transform, data, map_items, unpack_items, lazy=lazy, overrides=overrides, log_stats=log_stats
         )

monai/transforms/transform.py

@@ -229,7 +229,7 @@ def randomize(self, data: Any) -> None:
         Raises:
             NotImplementedError: When the subclass does not override this method.
         """
-        raise NotImplementedError(f"Subclass {self.__class__.__name__} must implement this method.")
+        raise NotImplementedError(f"Subclass {self.__class__.__name__} must implement the randomize() method.")
 
 
 class Transform(ABC):