IOIO: added working analogInput example

Author: chrisws

ioio/src/main/java/ioio/lib/pc/PausedInputStream.java

@@ -0,0 +1,40 @@
+package ioio.lib.pc;
+
+import java.io.BufferedInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * Pause between read() to avoid excessive CPU usage
+ */
+class PausedInputStream extends BufferedInputStream {
+  public PausedInputStream(InputStream inputStream) {
+    super(inputStream);
+  }
+
+  @Override
+  public synchronized int read(byte[] bytes, int i, int i1) throws IOException {
+    pause();
+    return super.read(bytes, i, i1);
+  }
+
+  @Override
+  public int read(byte[] bytes) throws IOException {
+    pause();
+    return super.read(bytes);
+  }
+
+  @Override
+  public synchronized int read() throws IOException {
+    pause();
+    return super.read();
+  }
+
+  private void pause() throws IOException {
+    try {
+      Thread.sleep(10);
+    } catch (InterruptedException e) {
+      throw new IOException(e);
+    }
+  }
+}

ioio/src/main/java/ioio/lib/pc/SerialPortIOIOConnection.java

@@ -68,11 +68,10 @@ public void waitForConnect() throws ConnectionLostException {
             serialPort_.enableReceiveThreshold(1);
             serialPort_.enableReceiveTimeout(500);
 
-            inputStream_ = new FixedReadBufferedInputStream(new GracefullyClosingInputStream(serialPort_.getInputStream()), 1024);
+            inputStream_ = new FixedReadBufferedInputStream(new PausedInputStream(serialPort_.getInputStream()), 1024);
             outputStream_ = new BufferedOutputStream(serialPort_.getOutputStream(), 256);
 
-            // This is only required on Windows and OSX El Capitan, but otherwise
-            // harmless.
+            // This is only required on Windows and OSX El Capitan, but otherwise harmless.
             //serialPort_.setDTR(false);
             serialPort_.setDTR(true);
             Thread.sleep(100);

ioio/src/main/java/net/sourceforge/smallbasic/ioio/IOService.java

@@ -88,7 +88,7 @@ public void incompatible(IOIO ioio) {
 
     @Override
     public void loop() throws ConnectionLostException, InterruptedException {
-      Thread.sleep(100);
+      Thread.sleep(10);
       for (IOTask next: ioTasks) {
         next.loop();
       }