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 в thread, скажем, 3. Обработчик завершения срабатывает во многих разных потоках и вызывает работу case NSStreamEvent.HasSpaceAvailable: в потоке 3, а также все потоки, в которых они существуют.

Мой вопрос: Как сделать так, чтобы self.stream(self.output, handleEvent: NSStreamEvent.hasSpaceAvailable) был вызывается в потоке 3 или какой-либо исходный поток w чтобы предотвратить это отключение друг от друга в выходной фазе.

Заранее благодарен!

Примечание: Поток, который содержит обработку ввода/вывод был создан с NSThread.detachNewThreadSelector

Answer 1

Хорошо, для любопытного зрителя I, с помощью от комментариев на вопрос, я понял, как сделать то, что я первоначально заданный в вопросе (независимо от того, переписывается ли это в конечном итоге для использования 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 или имеете запасной корпус, который порождает новый поток.