JavaCVを使用した同時ビデオフレーム処理

Question

JavaCVを使用してフレーム単位でビデオフレームをフィルタリングするコードがあります。コードは

try (FFmpegFrameGrabber grabber = createGrabber()) { 
    grabber.start(); 
    try (FFmpegFrameRecorder recorder = createRecorder(grabber)) { 
     recorder.start(); 
     Frame frame; 
     while ((frame = grabber.grab()) != null) { 
      Frame editedFrame = filterFrame(frame); //This takes a long time. 
      recorder.setTimestamp(grabber.getTimestamp()); 
      recorder.record(editedFrame); 
     } 
    } 
} 

以下の行Frame editedFrame = filterFrame(frame);は非常に長い時間がかかるされているためのように、それは全体のプロセスは非常に速くできるようにマルチスレッドを利用することができますか？私はExecutorServiceまたはLinkedBlockingQueueのようなものを使って、一度に複数のフレームを処理し、タイムスタンプに従ってフレームを記録することを考えていました。

Answer 1

それはpattern producerです：

プロデューサークラスが長いタスク（filterFrame）を実行するためにされています

import java.util.concurrent.Callable; 

public class Producer implements Callable<Frame> { 

    private final Frame frame; 

    public Producer(Frame frame) { 
     this.frame = frame; 
    } 

    @Override 
    public Frame call() throws Exception { 
     return filterFrame(frame); 
    } 
} 

Consumerクラスをストアフレームのためである：

import java.util.Map; 
import java.util.concurrent.BlockingQueue; 
import java.util.concurrent.Future; 
import java.util.concurrent.LinkedBlockingQueue; 
import java.util.concurrent.TimeUnit; 

public class Consumer implements Runnable { 

    private final BlockingQueue<Map.Entry<Long, Future<Frame>>> queue; 
    public Boolean continueProducing = Boolean.TRUE; 
    private final FFmpegFrameRecorder recorder; 

    public Consumer(FFmpegFrameRecorder recorder, 
        BlockingQueue<Map.Entry<Long, Future<Frame>>> queue) { 
     this.recorder = recorder; 
     this.queue = queue; 
    } 

    @Override 
    public void run() { 
     try { 
      Map.Entry<Long, Future<Frame>> entry = this.queue.poll(2, TimeUnit.SECONDS); 
      Frame editedFrame = entry.getValue().get(); 
      recorder.setTimestamp(entry.getKey()); 
      recorder.record(editedFrame); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    } 
} 

とタスクを管理する主要部分およびシャットダウンthreadPool

try (FFmpegFrameGrabber grabber = createGrabber()) { 
      grabber.start(); 
      try (FFmpegFrameRecorder recorder = createRecorder(grabber)) { 
       recorder.start(); 
       Frame frame; 
       ExecutorService threadPool = Executors.newWorkStealingPool(); 
       BlockingQueue<Map.Entry<Long, Future<Frame>>> queue = new LinkedBlockingQueue<>(); 
       threadPool.execute(new Consumer(recorder, queue)); 
       while ((frame = grabber.grab()) != null) { 
        queue.put(new Map.Entry<Long, Future<Frame>>() { 
         @Override 
         public Long getKey() { 
          return grabber.getTimestamp(); 
         } 

         @Override 
         public Future<Frame> getValue() { 
          return threadPool.submit(new Producer(frame)); // Frame editedFrame = filterFrame(frame); //This takes a long time. 
         } 

         @Override 
         public Future<Frame> setValue(Future<Frame> value) { 
          return null; 
         } 
        }); 
       } 
       threadPool.shutdownNow(); 
      } 
     } 

注：コピー＆ペーストのソリューションではなく、コードのカスタマイズが必要です。より多くの情報を共有すると、私はそれを変更します