Wait for parking handle to be published

Author: bbrockbernd

atomicfu/src/concurrentTest/kotlin/kotlinx/atomicfu/locks/ThreadParkerTest.kt

@@ -16,39 +16,44 @@ class ThreadParkerTest {
             ParkingSupport.park(Duration.INFINITE)
         }
 
-        // Allow thread to be parked before park call
+        // Allow thread to be parked before unpark call
         sleepMillis(100)
         ParkingSupport.unpark(parkingHandle!!)
 
         f.waitThrowing()
     }
-    
 
     @Test
     fun unparkPark() {
-        var parkingHandle: ParkingHandle? = null
+        val atomicHandle = AtomicParkingHandle()
         val unparked = AtomicBoolHolder(false)
 
         val f = Fut {
-            parkingHandle = ParkingSupport.currentThreadHandle()
+            atomicHandle.atomicHandle.value = ParkingSupport.currentThreadHandle()
 
             while (!unparked.atomicBool.value) { 
                 sleepMillis(10) 
             }
 
             ParkingSupport.park(Duration.INFINITE)
         }
-        
-        // allow testThread to start and publish handle
-        sleepMillis(100)
 
-        ParkingSupport.unpark(parkingHandle!!)
+        while (atomicHandle.atomicHandle.value == null) {
+            sleepMillis(10)
+        }
+
+        ParkingSupport.unpark(atomicHandle.atomicHandle.value!!)
         unparked.atomicBool.value = true
 
         f.waitThrowing()
 
     }
-    
+
+    // Needs to be in class otherwise build complains having an atomic outside of constructor
+    private class AtomicParkingHandle() {
+        val atomicHandle = atomic<ParkingHandle?>(null)
+    }
+
     // Needs to be in class otherwise build complains having an atomic outside of constructor
     private class AtomicBoolHolder(initial: Boolean) {
         val atomicBool = atomic(initial)