From 4df0a73605d9f8aef5e096ae2353b32b2913dbf8 Mon Sep 17 00:00:00 2001
From: Antoine Martin <totaam@xpra.org>
Date: Fri, 19 Jul 2019 15:09:17 +0000
Subject: [PATCH] test atomic threading

git-svn-id: https://xpra.org/svn/Xpra/trunk@23220 3bb7dfac-3a0b-4e04-842a-767bc560f471
---
 src/unittests/unit/util_test.py | 26 +++++++++++++++++++++++++-
 1 file changed, 25 insertions(+), 1 deletion(-)

diff --git a/src/unittests/unit/util_test.py b/src/unittests/unit/util_test.py
index 1921be01a6..b3ac73bf25 100755
--- a/src/unittests/unit/util_test.py
+++ b/src/unittests/unit/util_test.py
@@ -30,7 +30,31 @@ def _test_IntegerClass(self, IntegerClass):
 
     def test_AtomicInteger(self):
         self._test_IntegerClass(AtomicInteger)
-        #TODO: test lock with threading
+
+    def test_AtomicInteger_threading(self):
+        a = AtomicInteger()
+        N = 5000
+        def increase():
+            for _ in range(N):
+                a.increase()
+        def decrease():
+            for _ in range(N):
+                a.decrease()
+        T = 20
+        from threading import Thread
+        threads = []
+        for i in range(T):
+            if i%2==0:
+                target = increase
+            else:
+                target = decrease
+            t = Thread(target=target, name=str(target))
+            t.daemon = True
+            threads.append(t)
+        for t in threads:
+            t.start()
+        for t in threads:
+            t.join()
 
     def test_MutableInteger(self):
         self._test_IntegerClass(MutableInteger)