From 08bcd975943ad18c2617eadb117f7335b96f63a4 Mon Sep 17 00:00:00 2001
From: Cameron Gutman <aicommander@gmail.com>
Date: Mon, 29 May 2017 20:11:39 -0700
Subject: [PATCH] Use a less power intensive way of keeping the DVFS state
 friendly

---
 .../video/MediaCodecDecoderRenderer.java      | 52 ++++++++++++-------
 1 file changed, 33 insertions(+), 19 deletions(-)

diff --git a/app/src/main/java/com/limelight/binding/video/MediaCodecDecoderRenderer.java b/app/src/main/java/com/limelight/binding/video/MediaCodecDecoderRenderer.java
index bbf15b1b..1027759b 100644
--- a/app/src/main/java/com/limelight/binding/video/MediaCodecDecoderRenderer.java
+++ b/app/src/main/java/com/limelight/binding/video/MediaCodecDecoderRenderer.java
@@ -31,7 +31,8 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
     private MediaCodecInfo hevcDecoder;
 
     private MediaCodec videoDecoder;
-    private Thread rendererThread, spinnerThread;
+    private Thread rendererThread;
+    private Thread[] spinnerThreads;
     private boolean needsSpsBitstreamFixup, isExynos4;
     private boolean adaptivePlayback, directSubmit;
     private boolean constrainedHighProfile;
@@ -97,6 +98,8 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
     public MediaCodecDecoderRenderer(int videoFormat) {
         //dumpDecoders();
 
+        spinnerThreads = new Thread[Runtime.getRuntime().availableProcessors()];
+
         avcDecoder = findAvcDecoder();
         if (avcDecoder != null) {
             LimeLog.info("Selected AVC decoder: "+avcDecoder.getName());
@@ -346,19 +349,26 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
         rendererThread.start();
     }
 
-    private void startSpinnerThread() {
-        spinnerThread = new Thread() {
-            @Override
-            public void run() {
-                // This thread exists to keep the CPU at a higher DVFS state on devices
-                // where the governor scales clock speed sporadically, causing dropped frames.
-                while (!isInterrupted()) {
-                    Thread.yield();
+    private void startSpinnerThreads() {
+        LimeLog.info("Using "+spinnerThreads.length+" spinner threads");
+        for (int i = 0; i < spinnerThreads.length; i++) {
+            spinnerThreads[i] = new Thread() {
+                @Override
+                public void run() {
+                    // This thread exists to keep the CPU at a higher DVFS state on devices
+                    // where the governor scales clock speed sporadically, causing dropped frames.
+                    while (!isInterrupted()) {
+                        try {
+                            Thread.sleep(0, 1);
+                        } catch (InterruptedException e) {
+                            break;
+                        }
+                    }
                 }
-            }
-        };
-        spinnerThread.setPriority(Thread.MIN_PRIORITY);
-        spinnerThread.start();
+            };
+            spinnerThreads[i].setPriority(Thread.MIN_PRIORITY);
+            spinnerThreads[i].start();
+        }
     }
 
     private int dequeueInputBuffer() {
@@ -392,7 +402,7 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
     @Override
     public void start() {
         startRendererThread();
-        startSpinnerThread();
+        startSpinnerThreads();
     }
 
     @Override
@@ -405,11 +415,15 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
             rendererThread.join();
         } catch (InterruptedException ignored) { }
 
-        // Halt the spinner thread
-        spinnerThread.interrupt();
-        try {
-            spinnerThread.join();
-        } catch (InterruptedException ignored) { }
+        // Halt the spinner threads
+        for (Thread t : spinnerThreads) {
+            t.interrupt();
+        }
+        for (Thread t : spinnerThreads) {
+            try {
+                t.join();
+            } catch (InterruptedException ignored) { }
+        }
     }
 
     @Override