Minor version bump.

 - Use `threading.Lock` over `multiprocessing.Lock`.
 - Add tests for thread-safety.

Author: hjpotter92

sonyflake/about.py

@@ -1,7 +1,7 @@
 from typing import Dict
 
 MAJOR: int = 1
-MINOR: int = 0
+MINOR: int = 1
 PATCH: int = 0
 SUFFIX: str = ""
 

sonyflake/sonyflake.py

@@ -1,7 +1,7 @@
 import datetime
 import ipaddress
-from multiprocessing import Lock
 from socket import gethostbyname, gethostname
+from threading import Lock
 from time import sleep
 from typing import Callable, Dict, Optional
 

tests/test_sonyflake.py

@@ -1,5 +1,4 @@
-import multiprocessing
-from collections import Counter
+import threading
 from datetime import datetime, timedelta
 from random import randint
 from time import sleep
@@ -64,3 +63,16 @@ def test_sonyflake_for_10sec(self):
         self.assertEqual(
             max_sequence, (1 << BIT_LEN_SEQUENCE) - 1, "Unexpected max sequence"
         )
+
+    def test_sonyflake_in_parallel(self):
+        threads = []
+        results = []
+        for _ in range(10000):
+            thread = threading.Thread(target=lambda: results.append(self.sf.next_id()))
+            thread.start()
+            threads.append(thread)
+        for thread in threads:
+            thread.join()
+        result_set = set(results)
+        self.assertEqual(len(results), len(result_set))
+        self.assertCountEqual(results, result_set)