スレッドインスタンスでブロックを実行するには？

Question

URLSession.shared.downloadTaskリクエストを実行しましたが、downloadTaskが実行されたのと同じスレッドでコードを実行したいとします。例：

func sample() { 
    let thread = Thread.current 

    URLSession.shared.downloadTask(with: file) { 
     someFunc() //How to execute on thread variable? 
    }.resume() 
} 

完了ハンドラでは、バックグラウンドスレッドで実行されています。しかし、someFunc()と同じスレッドsample()が呼び出されました。私はThread.current.async {...}のようなものは、私はこれを行うことができますするにはどうすればよい：あなたは、特定のThread上で何かを実行したい場合は

func sample() { 
    let thread = Thread.current 

    URLSession.shared.downloadTask(with: file) { 
     thread.async { someFunc() } //Doesn't compile 
    }.resume() 
} 

Answer 1

、あなたはむしろちょうどこのGCDのAPIを使用しますが、ではないでしょう：

perform(#selector(someMethod), on: thread, with: nil, waitUntilDone: false, modes: [RunLoopMode.commonModes.rawValue]) 

もちろんのこと、例えば、あなたが実行ループでスレッドを作成することを前提としています

let thread = Thread(target: self, selector: #selector(threadEntryPoint), object: nil) 
thread.start() 

と

func threadEntryPoint() { 
    autoreleasepool { 
     Thread.current.name = "com.domain.app.background" 
     let runLoop = RunLoop.current 
     runLoop.add(NSMachPort(), forMode: .defaultRunLoopMode) 
     runLoop.run() 
    } 
} 

詳細については、Threading Programming Guideを参照してください。

個人的には、人間的に可能であれば私は個人的にGCDにとどまりますが、他の場所ではそれを排除する独自の要件があると言っています。

Answer 2

Thread.current.asyncのように、コンパイルされない理由はありません。

sampleとsomeFuncを同じスレッドで実行する場合は、OperationとOperationQueueを使用できます。この方法の欠点は、 が1つのスレッドをブロックしていることです。

var myQueue:OperationQueue = { 
    let q = OperationQueue() 
    q.name = "downloadQueue" 
    // if you want to limit concurrent operation 
    q.maxConcurrentOperationCount = 5 
    return q 
}() 


class DowloadOperation :Operation { 

    enum State { 
     case Ready, Executing, Finished 
     // ... 
    } 

    var state = State.Ready { 
     willSet { 
      ... 
     } 
     didSet { 
      ... 
     } 
    }  

    override func start() { 
     if self.isCancelled { 
      state = .Finished 
     } else { 
      state = .Ready 
      main() 
     } 
    } 

    override var isFinished: Bool { 
     get { 
      return state == .Finished 
     } 
    } 

    override var isAsynchronous: Bool { 
     get { 
      return true 
     } 
    } 

    override var isExecuting: Bool { 
     get { 
      return state == .Executing 
     } 
    } 


    override func main() { 
     if self.isCancelled { 
      self.state == .Finished 
      return 
     } 

     state = .Executing 

     URLSession.shared.downloadTask(with: file) { 
      // ... 
      state = .Finished 
     } 

     }.resume() 
    } 
} 

func someFunc() { 
    ... 
} 

// sample and someFunc are executed on the same thread 
// you loose the advantage of the async download. 
func sample() { 
    downloadOp = DownloadOperation() 
    myQueue.addOperation(downloadOp) 
    downloadOp.waitUntilFinished() 
    someFunc() 
}