src/kaka/cakelight/VideoMode.java

   1 package kaka.cakelight;
   2
   3 import java.io.File;
   4 import java.io.IOException;
   5 import java.util.Optional;
   6 import java.util.function.Consumer;
   7
   8 public class VideoMode implements Mode, Consumer<Optional<File>> {
   9     private Configuration config;
  10     private Thread thread;
  11     private Consumer<Frame> frameConsumer;
  12     private VideoDeviceListener deviceListener;
  13
  14     public VideoMode() {
  15         deviceListener = new VideoDeviceListener();
  16         deviceListener.onVideoDeviceChange(this);
  17     }
  18
  19     @Override
  20     public void enter(Configuration config) {
  21         this.config = config;
  22         deviceListener.startListening();
  23     }
  24
  25     @Override
  26     public void exit() {
  27         thread.interrupt();
  28         deviceListener.stopListening();
  29     }
  30
  31     private void startGrabberThread(File videoDevice) {
  32         assert frameConsumer != null;
  33         thread = new Thread() {
  34             public void run() {
  35                 try (FrameGrabber grabber = FrameGrabber.from(videoDevice, config)) {
  36                     while (!isInterrupted()) {
  37 //                        Optional<Frame> frame = grabber.grabFrame();
  38                         grabber.grabFrame().ifPresent(frameConsumer);
  39 //                        timeIt("frame", grabber::grabFrame);
  40                         // TODO: process frame
  41                         // TODO: save where the LedController can access it
  42                     }
  43                 } catch (IOException e) {
  44                     e.printStackTrace();
  45                 }
  46             }
  47         };
  48         thread.start();
  49     }
  50
  51     public void onFrame(Consumer<Frame> consumer) {
  52         frameConsumer = consumer;
  53     }
  54
  55     @Override
  56     public void accept(Optional<File> videoDevice) {
  57         // Should only happen when this mode is active!
  58         if (thread != null) {
  59             thread.interrupt();
  60         }
  61         videoDevice.ifPresent(this::startGrabberThread);
  62     }
  63 }