Merge branch 'ts_backend_PR' into ts_backend

sameeul · Apr 15, 2024 · 67db827 · 67db827
2 parents 6733a33 + 528f93f
commit 67db827
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/bfio/base_classes.py b/src/bfio/base_classes.py
@@ -1,5 +1,6 @@
 # -*- coding: utf-8 -*-
 import abc
+import multiprocessing
 import numpy
 import ome_types
 import threading
@@ -107,6 +108,15 @@ def __init__(
             file_path = Path(file_path)
         self._file_path = file_path
 
+        self._max_workers = (
+            max_workers
+            if max_workers is not None
+            else max([multiprocessing.cpu_count() // 2, 1])
+        )
+
+        # Create an thread lock for the object
+        self._lock = threading.Lock()
+
     def __setitem__(self, keys: typing.Union[list, tuple], values: numpy.ndarray):
         raise NotImplementedError(
             "Cannot set values for {} class.".format(self.__class__.__name__)