iOS 套接字输入流阻塞 UI，但未安排在主线程上

Question

当我的应用程序通过网络输入流接收数据时，会在主线程上调用相应的 streamDelegate。当接收到大量数据时，UI block 明显。我试图从

触发所有相应的功能

DispatchQueue.global(qos: .whatever).sync()

虽然

inputStream.schedule(in: .current,forMode: .commonModes)

在该队列中被调用，streamDelegate 仍然在 Main 上被调用？!

根据我的阅读和理解，直到现在，.sync 无论如何也帮不了我，因为它仍然会阻塞 UI，因为它会等待完成，然后再将控制权交还给 UI。所以我对 .async 进行了同样的尝试。当所有流的东西都在异步线程上工作时，outputStream 工作正常，但 inputStreams 的 streamDelegate 不会触发。我没有收到回复。

我做错了什么？

class AppDelegate {
  let mSocketClass = SocketClass()
  func application(_:){
    DispatchQueue.global(qos: .utility).async(){
      mSocketClass.setupNetworkCommunication()
      mSocketClass.sendStuff()
    }
  } 
}

.

class SocketClass:NSObject {
  var mInputStream: InputStream!
  var mOutputStream: OutputStream!

  func setupNetworkCommunication(){
    var readStream: Unmanaged<CFReadStream>?
    var writeStream: Unmanaged<CFWriteStream>?
    CFStreamCreatePairWithSocketToHost(kCFAllocatorDefault, "example.com" as CFString, 1234, &readStream, &writeStream)
    mInputStream = readStream!.takeRetainedValue()
    mOutputStream = writeStream!.takeRetainedValue()
    mInputStream.schedule(in: .current, forMode: .commonModes) //happens on thread other than Main
    mOutputStream.schedule(in: .current, forMode: .commonModes)
    mInputStream.open()
    mOutputStream.open()
    mInputStream.delegate = self
  }

  func sendStuff(){
    if mOutputStream.hasSpaceAvailable {
      mOutputStream.write(...)
    }
  }
}

extension SocketClass:StreamDelegate{
  func stream(_ aStream: Stream, handle eventCode: Stream.Event) {
    switch eventCode {
      case Stream.Event.hasBytesAvailable:
        (aStream as! InputStream).read(...) //happens on Main
    }
  }
}

顺便说一句:我不喜欢使用框架的解决方案。在我看来，解决方案是更改我不明白的一行。

谢谢!

Answer 1

代码几乎没问题，但您需要在该线程上启动一个运行循环。

所以它应该是这样的:

DispatchQueue.global(qos: .utility).async(){
    self.mSocketClass.setupNetworkCommunication()
    RunLoop.current.run()
}

请注意:

• RunLoop.current.run() 永远不会返回。应该是您设置中的最后一行。
• 然后在后台线程上接收数据。如果你想在接收数据后更新你的用户界面，你必须使用 DispatchQueue.main.async() {/* UI updates */}

让我知道它是如何为您服务的。