メモリを使い果たすことなく、できるだけMacOSアプリケーションのタスクを並列化するにはどうすればよいですか？

Question

私はMacOS上で動作するSwiftアプリケーションを持っています。イメージをバッチ処理します。私は、これらのイメージがどれだけ大きくなるのか、そして私のアプリケーションがどのハードウェア上で実行されるのかを事前に知っていません。これらは両方ともユーザーに依存しています。

GCDを使用して、画像の処理を並列化して、実際にスループットを向上させることができます。

しかし、場合によっては、並列化が高すぎると、ユーザーが高解像度の画像を処理すると、並列化が多すぎるメモリ圧迫を引き起こし、システムのパフォーマンスが非常に悪くなります。

私はRAM内で作業負荷を維持しながら並列化を最大化する速度で「並列タスクプロセッサを使用する」方法を見つけたいと思います（&のスワッピングを呼び出すトリガーはありません）。ディスクIO）。

これを行う方法に関するアイデアはありますか？

Answer 1

私はトークンバケットタイプのシングルトンを実装しました。シングルトンは、メモリ要件に基づいてアドミッションコントロールを処理します。 RAMの80％が私のアプリケーションで使用できるように初期化されます。

let memoryGate = MemoryGate(maxBytes: ProcessInfo.processInfo.physicalMemory*8/10) 

誰かがメモリ集約型操作を実行したい場合、そのメモリから要求（）する必要があります。十分なメモリがない場合、コールはブロックされるまでブロックされます。終了後、スレッドはメモリーを解放（）しなければなりません。

コード：

class MemoryGate { 

    private let maxBytes : UInt64 
    private var availableBytes : Int64 

    private let cv = NSCondition() 

    init(maxBytes: UInt64) { 
     self.maxBytes = maxBytes 
     self.availableBytes = Int64(maxBytes) 
     Log.debug?.message("maxBytes=\(maxBytes)") 
    } 

    public func request(amount: UInt64) { 
     Log.debug?.message("Resquesting \(amount) bytes") 
     cv.lock() 

     // If the amount is bigger than the max allowed, no amount of waiting is going 
     // to help, so we go through and let the other smaller jobs be held back until 
     // memory is freed 
     if (amount <= maxBytes) { 
      while (availableBytes < Int64(amount)) { 
       cv.wait() 
      } 
     } 

     availableBytes -= Int64(amount) 

     Log.debug?.message("Got \(amount) bytes. availableBytes=\(availableBytes)") 
     cv.unlock() 
    } 

    public func release(amount: UInt64) { 
     cv.lock() 
     availableBytes += Int64(amount) 
     Log.debug?.message("Released \(amount) bytes. availableBytes=\(availableBytes)") 
     cv.broadcast() 
     cv.unlock() 
    } 
} 

Answer 2

メモリ圧力イベントのためのGCD dispatch sourceがあります。あなたのコードがどのように構造化されているかはわかりませんが、DISPATCH_MEMORYPRESSURE_WARNイベントが発生するまで並列タスクを作成してから、タスクをやめたり、