This repository has been archived on 2024-10-27. You can view files and clone it, but cannot push or open issues or pull requests.
|
import threading
|
|
|
|
|
|
class ThreadSafeInteger:
|
|
def __init__(self, value=0):
|
|
self.value = value
|
|
self._value_lock = threading.Lock()
|
|
|
|
def increment(self):
|
|
with self._value_lock:
|
|
self.value += 1
|
|
return self.value
|