From: Scott Gasch <scott@gasch.org>
Date: Fri, 9 Jun 2023 01:38:07 +0000 (-0700)
Subject: Simple base interfaces.
X-Git-Url: https://wannabe.guru.org/gitweb/?a=commitdiff_plain;h=3ec0903903aec12b01c3eef42c8eb944fe00c90f;p=pyutils.git

Simple base interfaces.
---

diff --git a/src/pyutils/collectionz/shared_dict.py b/src/pyutils/collectionz/shared_dict.py
index dba30e5..e3324cb 100644
--- a/src/pyutils/collectionz/shared_dict.py
+++ b/src/pyutils/collectionz/shared_dict.py
@@ -48,6 +48,8 @@ from typing import (
     ValuesView,
 )
 
+from pyutils.typez.typing import Closable
+
 
 class PickleSerializer:
     """A serializer that uses pickling.  Used to read/write bytes in the shared
@@ -71,7 +73,7 @@ class PickleSerializer:
 # whole thing?
 
 
-class SharedDict(object):
+class SharedDict(Closable):
     """This class emulates the dict container but uses a
     `Multiprocessing.SharedMemory` region to back the dict such that it
     can be read and written by multiple independent processes at the
diff --git a/src/pyutils/parallelize/thread_utils.py b/src/pyutils/parallelize/thread_utils.py
index 43e6294..4e891f1 100644
--- a/src/pyutils/parallelize/thread_utils.py
+++ b/src/pyutils/parallelize/thread_utils.py
@@ -10,6 +10,8 @@ import os
 import threading
 from typing import Any, Callable, Optional, Tuple
 
+from pyutils.typez.typing import Runnable
+
 # This module is commonly used by others in here and should avoid
 # taking any unnecessary dependencies back on them.
 
@@ -132,7 +134,7 @@ def background_thread(
         return wrapper(_funct)
 
 
-class ThreadWithReturnValue(threading.Thread):
+class ThreadWithReturnValue(threading.Thread, Runnable):
     """A thread whose return value is plumbed back out as the return
     value of :meth:`join`.  Use like a normal thread::
 
diff --git a/src/pyutils/typez/typing.py b/src/pyutils/typez/typing.py
index 18cf4ef..bed5e7f 100644
--- a/src/pyutils/typez/typing.py
+++ b/src/pyutils/typez/typing.py
@@ -28,3 +28,24 @@ class Comparable(Protocol):
     @abstractmethod
     def __eq__(self, other: Any) -> bool:
         ...
+
+
+class Closable(Protocol):
+    """Something that can be closed."""
+
+    def close(self) -> None:
+        ...
+
+
+class Cloneable(Protocol):
+    """Something that can be cloned."""
+
+    def clone(self) -> None:
+        ...
+
+
+class Runnable(Protocol):
+    """Something that can be run."""
+
+    def run(self) -> None:
+        ...