使用Android 平台的接口设置线程优先级

SilenceDut · Apr 18, 2019 · daf99e0 · daf99e0
1 parent da39b71
commit daf99e0
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 12 deletions.
diff --git a/.idea/modules.xml b/.idea/modules.xml
diff --git a/taskscheduler/src/main/java/com/silencedut/taskscheduler/ThreadFactory.java b/taskscheduler/src/main/java/com/silencedut/taskscheduler/ThreadFactory.java
@@ -10,36 +10,43 @@
  */
 class ThreadFactory {
 
+    static final class BackgroundRunnable implements Runnable {
+        private Runnable runnable;
+        BackgroundRunnable(Runnable runnable) {
+            this.runnable = runnable;
+        }
+
+        @Override
+        public void run() {
+            Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
+            runnable.run();
+        }
+    }
+
     static final java.util.concurrent.ThreadFactory TASKSCHEDULER_FACTORY = new java.util.concurrent.ThreadFactory() {
         private final AtomicInteger mCount = new AtomicInteger(1);
 
         @Override
         public Thread newThread(Runnable r) {
-            Thread thread = new Thread(r, "TaskScheduler  #" + mCount.getAndIncrement());
-            thread.setPriority(Process.THREAD_PRIORITY_BACKGROUND);
-            return thread;
+            return new Thread(new BackgroundRunnable(r), "TaskScheduler  #" + mCount.getAndIncrement());
         }
     };
 
-     static final java.util.concurrent.ThreadFactory TIME_OUT_THREAD_FACTORY = new java.util.concurrent.ThreadFactory() {
+    static final java.util.concurrent.ThreadFactory TIME_OUT_THREAD_FACTORY = new java.util.concurrent.ThreadFactory() {
         private final AtomicInteger mCount = new AtomicInteger(1);
 
         @Override
         public Thread newThread(Runnable r) {
-            Thread thread = new Thread(r, "TaskScheduler timeoutThread #" + mCount.getAndIncrement());
-            thread.setPriority(Process.THREAD_PRIORITY_BACKGROUND);
-            return thread;
+            return new Thread(new BackgroundRunnable(r), "TaskScheduler timeoutThread #" + mCount.getAndIncrement());
         }
     };
 
     static final java.util.concurrent.ThreadFactory SCHEDULER_THREAD_FACTORY = new java.util.concurrent.ThreadFactory() {
         private final AtomicInteger mCount = new AtomicInteger(1);
 
         @Override
-        public Thread newThread( Runnable r) {
-            Thread thread = new Thread(r, "TaskScheduler scheduler #" + mCount.getAndIncrement());
-            thread.setPriority(Process.THREAD_PRIORITY_BACKGROUND);
-            return thread;
+        public Thread newThread(Runnable r) {
+            return new Thread(new BackgroundRunnable(r), "TaskScheduler scheduler #" + mCount.getAndIncrement());
         }
     };
 }