Swift 2 - iOS - Công văn trở lại chủ đề ban đầu

Question

Vì vậy, tôi có một ứng dụng kích hoạt một loạt các sự kiện không đồng bộ và sau đó ghi kết quả vào bộ đệm. Vấn đề là tôi muốn bộ đệm để được ghi vào đồng bộ (trong các chủ đề mà sinh ra các quá trình không đồng bộ)

đang skeleton là như vậy

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 
    } 
} 

Vấn đề là các chủ đề mà các cuộc gọi là dataTaskWithRequest là trong thread, nói, 3. xử lý hoàn thành cháy trong nhiều chủ đề khác nhau và nguyên nhân case NSStreamEvent.HasSpaceAvailable: để được chạy trong chủ đề 3, cộng với tất cả các chủ đề mà họ tồn tại.

Câu hỏi của tôi là: Làm thế nào để làm cho nó để self.stream(self.output, handleEvent: NSStreamEvent.hasSpaceAvailable) là được gọi trong chuỗi 3, hoặc chủ đề ban đầu để ngăn chặn sự vấp ngã này của nhau trong pha đầu ra.

Cảm ơn trước!

LƯU Ý: Các chủ đề có chứa các xử lý đầu vào/đầu ra đã được tạo ra với NSThread.detachNewThreadSelector

Answer 1

Alright, cho người xem tò mò tôi, với sự giúp đỡ từ bình luận cho câu hỏi tôi đã tìm ra cách để làm những gì tôi ban đầu được hỏi trong câu hỏi (có hay không điều này cuối cùng được viết lại để sử dụng GCD là một câu hỏi khác)

Giải pháp (với phạm vi tăng nhẹ vào mã) là sử dụng performSelector với một chuỗi cụ thể.

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 
    } 
} 
} 

Vì vậy, hãy sử dụng performSelector trên đối tượng có bộ chọn và sử dụng nút onThread để cho biết chuỗi cần chuyển đến. Tôi kiểm tra cả trước khi thực hiện chọn và trước khi thực hiện cuộc gọi để đảm bảo rằng đầu ra có dung lượng trống (đảm bảo rằng tôi không tự mình đi qua)

Answer 2

Nó sẽ không cho phép tôi nhận xét về chủ đề ở trên (đây là những gì tôi nhận được để rình rập), nhưng một điều cần lưu ý là mã hiện tại của bạn có thể bế tắc giao diện người dùng của bạn nếu bạn sử dụng waitUntilDone hoặc performBlockAndWait.

Nếu bạn đi tuyến đường đó, bạn cần phải chắc chắn rằng bạn không gọi nó từ mainThread hoặc có trường hợp dự phòng sinh ra một chuỗi mới.