Swift 2 - iOS - 发回原始线程

Question

因此，我有一个应用程序触发一系列异步事件，然后将结果写入缓冲区。的问题是，我想要的缓冲器被写入到同步（在产生了异步处理的线程）

骨架码作为这样

let Session = NSURLSession.sharedSession() 
let TheStack = [Structure]() 
//This gets called asynchronously, e.g. in threads 3,4,5,6,7 
func AddToStack(The Response) -> Void { 
    TheStack.insertAt(Structure(The Response), atIndex: 0)) 
    if output.hasSpaceAvailable == true { 
     // This causes the stream event to be fired on mutliple threads 
     // This is what I want to call back into the original thread, e.g. in thread 2 
     self.stream(self.output, handleEvent: NSStreamEvent.hasSpaceAvailable) 
    } 
} 

// This is in the main loop, e.g. thread 2 
func stream(aStream: NSStream, handleEvent: NSStreamEvent) { 

    switch(NSStreamEvent) { 

     case NSStreamEvent.OpenCompleted: 
      // Do some open stuff 
     case NSStreamEvent.HasBytesAvailable: 
      Session.dataTaskWithRequest(requestFromInput, completionHandler: AddToStack) 
     case NSStreamEvent.HasSpaceAvailable: 
      // Do stuff with the output 
     case NSStreamEvent.CloseCompleted: 
      // Close the stuff 
    } 
} 

的问题是，调用线程dataTaskWithRequest是在线程，说，3.完成处理程序触发许多不同的线程，并导致case NSStreamEvent.HasSpaceAvailable:在线程3，加上他们存在的所有线程。

我的问题是：如何使它self.stream(self.output, handleEvent: NSStreamEvent.hasSpaceAvailable)是在线程3中调用，或者永远是原始线程w以防止在输出阶段相互跳闸。

在此先感谢！

注：包含输入/输出处理与NSThread.detachNewThreadSelector

创建

Answer 1

好吧，为好奇的旁观者我，与援助从评论的问题我已经找到了如何做我原来的线程在问题中询问（这是否最终被重写为使用GCD是一个不同的问题）

解决方案（在代码中的范围稍微增加）是使用performSelector和特定的线程。

final class ArbitraryConnection { 

internal var streamThread: NSThread 

let Session = NSURLSession.sharedSession() 
let TheStack = [Structure]() 
//This gets called asynchronously, e.g. in threads 3,4,5,6,7 
func AddToStack(The Response) -> Void { 
    TheStack.insertAt(Structure(The Response), atIndex: 0)) 
    if output.hasSpaceAvailable == true { 
     // This causes the stream event to be fired on multiple threads 
     // This is what I want to call back into the original thread, e.g. in thread 2 

     // Old way 
     self.stream(self.output, handleEvent: NSStreamEvent.hasSpaceAvailable) 
     // New way, that works 
     if(streamThread != nil) { 
      self.performSelector(Selector("startoutput"), onThread: streamThread!, withObject: nil, waitUntilDone: false) 
     } 
    } 
} 

func open -> Bool { 
    // Some stuff 
    streamThread = NSThread.currentThread() 
} 


final internal func startoutput -> Void { 
    if(output.hasSpaceAvailable && outputIdle) { 
     self.stream(self.output, handleEvent: NSStreamEvent.HasSpaceAvailable) 
    } 
} 
// This is in the main loop, e.g. thread 2 
func stream(aStream: NSStream, handleEvent: NSStreamEvent) { 

    switch(NSStreamEvent) { 

     case NSStreamEvent.OpenCompleted: 
      // Do some open stuff 
     case NSStreamEvent.HasBytesAvailable: 
      Session.dataTaskWithRequest(requestFromInput, completionHandler: AddToStack) 
     case NSStreamEvent.HasSpaceAvailable: 
      // Do stuff with the output 
     case NSStreamEvent.CloseCompleted: 
      // Close the stuff 
    } 
} 
} 

因此，在选择器上使用performSelector对象，并使用onThread来告诉它传递给哪个线程。我在执行选择器之前以及在执行调用之前检查以确保输出具有可用空间（请确保我不会绊倒自己）

Answer 2

它不会让我评论上面的线程（这是我潜藏的东西），但有一点需要注意的是，如果您使用waitUntilDone或performBlockAndWait，您当前的代码可能会导致您的用户界面死锁。

如果你走这条路线，你需要绝对确定你不要从mainThread调用这个函数，或者有一个产生新线程的回退情况。