Merge pull request #11 from ypopovych/master

Added locks on run loop creation. Removed logs

Author: dileping

ExecutionContext/ExecutionContext.swift

@@ -130,23 +130,14 @@ extension ExecutionContextType {
         var result:Result<ReturnType, AnyError>?
 
         let sema = LoopSemaphore()
-        let id = NSUUID().UUIDString
 
-        print("before async: ", id)
         async {
-            print("started async: ", id)
             result = materialize(task)
-            print("materialized: ", id)
             sema.signal()
-            print("signaled: ", id)
         }
 
-        print("will wait: ", id)
-        
         sema.wait()
 
-        print("did wait: ", id)
-        
         return try result!.dematerializeAnyError()
     }
 }

ExecutionContext/PThreadExecutionContext.swift

@@ -77,7 +77,6 @@
                 pthread_setspecific(key.key, nil)
             } else {
                 if retain {
-                    print("Pass retained \(obj)")
                     pthread_setspecific(key.key, UnsafePointer<Void>(Unmanaged.passRetained(obj!).toOpaque()))
                 } else {
                     pthread_setspecific(key.key, UnsafePointer<Void>(Unmanaged.passUnretained(obj!).toOpaque()))

ExecutionContext/RunLoop.swift

@@ -230,6 +230,7 @@ import CoreFoundation
         	Unmanaged<RunLoop>.fromOpaque(COpaquePointer(loop)).release()
         })
 
+        private static let threadLocalLock = NSLock()
         private static let MainRunLoop = RunLoop.createMainRunLoop()
 
         init(_ cfRunLoop: CFRunLoop) {
@@ -241,11 +242,16 @@ import CoreFoundation
 		}
 
         private static func createMainRunLoop() -> RunLoop {
+            defer {
+                RunLoop.threadLocalLock.unlock()
+            }
+
+            RunLoop.threadLocalLock.lock()
             let runLoop = RunLoop(CFRunLoopGetMain())
             if runLoop.isCurrent() {
                 PThread.setSpecific(runLoop, key: RunLoop.threadKey, retain: true)
             } else {
-                let sema = LoopSemaphore()
+                let sema = Semaphore()
                 runLoop.addTask({
                     PThread.setSpecific(runLoop, key: RunLoop.threadKey, retain: true)
                     sema.signal()
@@ -256,6 +262,10 @@ import CoreFoundation
         }
 
 		static func currentRunLoop() -> RunLoop {
+            defer {
+                RunLoop.threadLocalLock.unlock()
+            }
+            RunLoop.threadLocalLock.lock()
             guard let loop = PThread.getSpecific(RunLoop.threadKey) else {
                 let loop = RunLoop(CFRunLoopGetCurrent())
                 PThread.setSpecific(loop, key: RunLoop.threadKey, retain: true)
@@ -269,7 +279,6 @@ import CoreFoundation
 		}
 
 		func startTaskQueue(priority: Int = 1) {
-			print("Start queue called")
 			defer {
 				taskQueueLock.unlock()
 			}