scan and close led when play

 package com.gimi.common.cinema.utils;
 
-import android.annotation.SuppressLint;
 import android.content.Context;
+import android.media.MediaPlayer;
 import android.text.TextUtils;
 import android.util.Log;
 import com.gimi.common.cinema.model.AsyncCallback;
@@ -15,8 +15,18 @@ import com.xgimi.gimicinema.R;
 import com.xgimi.gimicinema.activity.CinemaConfig;
 
 import java.io.File;
+import java.io.IOException;
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.HashMap;
+import java.util.List;
+import java.util.concurrent.Callable;
+import java.util.concurrent.Future;
+import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicInteger;
 
 /**
  * movie scan
@@ -25,7 +35,6 @@ import java.util.HashMap;
 public class LocalMovieScanUtils {
     private String[] picExtensions;
     private String[] mediaExtensions;
-//    private ArrayList<SaveMessage> result = new ArrayList<>();
 
     public LocalMovieScanUtils(Context context) {
         picExtensions = context.getResources().getStringArray(R.array.photo_filter);
@@ -45,7 +54,7 @@ public class LocalMovieScanUtils {
                 FolderItem folderItem = new FolderItem();
                 folderItem.setFolderName(fileDir);
                 folderItem.setFolderPath(rootPath + fileDir + "/");
-//                if (fileDir.contains("3D")) {
+//                if (fileDir.contains("AQ")) {
                 types.add(folderItem);
 //                }
             }
@@ -181,6 +190,7 @@ public class LocalMovieScanUtils {
      * @return ArrayList<LocalMovieMessage>
      */
     ArrayList<LocalMovieMessage> getAllLocalMovie(String rootPath, String folder, AsyncCallback<Integer> callback) {
+        Log.d("scan-time", "start:" + System.currentTimeMillis());
         ArrayList<String> all = new ArrayList<>();
         File file = new File(rootPath);
         if (file.listFiles() != null) {
@@ -226,7 +236,7 @@ public class LocalMovieScanUtils {
                 moviesItems.addAll(getAllType(type.getFolderPath(), callback));
             }
         }
-//        FileReadUtils.writeDate(rootPath + "/length.txt", new Gson().toJson(result));
+        Log.d("scan-time", "  end:" + System.currentTimeMillis());
         return moviesItems;
     }
 
@@ -249,69 +259,193 @@ public class LocalMovieScanUtils {
      * @param callback callback
      * @return ArrayList<LocalMovieMessage>
      */
-    @SuppressLint("SdCardPath")
     private ArrayList<LocalMovieMessage> getAllType(String rootPath, AsyncCallback<Integer> callback) {
         ArrayList<LocalMovieMessage> movies = new ArrayList<>();
         if (rootPath.contains("lost+found")) {
             return movies;
         }
+        if (callback != null) {
+            String[] split = rootPath.split("/");
+            callback.onMessage(split[split.length - 1]);
+        }
         File file = new File(rootPath);
         String[] fileDirs = file.list();
         //遍历
         if (fileDirs == null || fileDirs.length == 0) {
             return movies;
         }
-        for (String fileDir : fileDirs) {
-            File curFiles = new File(rootPath + fileDir);
-            if (curFiles.isDirectory()) {
-                if (callback != null) {
-                    callback.onMessage(fileDir);
-                }
-                String curPath = curFiles.getAbsoluteFile().toString();
-                LocalMovieMessage moviesItem = new LocalMovieMessage();
-                String name = NameFilterUtils.getName(fileDir).trim();
-                moviesItem.setMovieName(name);
-                String allFirstSpell = PinyinUtil.getAllFirstSpell(name);
-                String newStr = allFirstSpell.replaceAll("[^\\w,]", "");
-                moviesItem.setNamePinyin(newStr);
-                String media = getMedia(curPath + "/", mediaExtensions);
-                String poster;
-                poster = MovieMessageUtils.getLocalMoviePoster(curPath);
-                if (TextUtils.isEmpty(poster)) {
-                    poster = getMediaPicture(curPath + "/", picExtensions);
-                }
-                if (!TextUtils.isEmpty(poster)) {
-                    moviesItem.setPosterPath(poster);
-                }
-                if (!TextUtils.isEmpty(media)) {
-                    File mFile = new File(media);
-                    long length = mFile.length();
-                    String md5 = MD5Utils.stringMD5(FileHashUtils.getFileHash(media));
-                    moviesItem.setMd5(md5);
-                    //read douban id and douban msg,至于name id 信息另外做，没有必要每次更新时都去添加
-                    try {
-                        setDoubanMsg(curPath, moviesItem);
-                    } catch (Exception e) {
-                        Log.e("otherError", media);
-                        e.printStackTrace();
+        int length = fileDirs.length;
+        int coreCount = 8;
+        int poolCount = 9;
+        ThreadPoolExecutor myExecutor = new ThreadPoolExecutor(coreCount, poolCount,
+                200, TimeUnit.SECONDS, new LinkedBlockingDeque<Runnable>());
+        List<Future<ArrayList<LocalMovieMessage>>> results = new ArrayList<>();
+        for (int i = 0; i < coreCount; i++) {
+            ScanTask task = new ScanTask(rootPath, Arrays.copyOfRange(
+                    fileDirs, length * i / coreCount, (length * (i + 1)) / coreCount));
+            Future<ArrayList<LocalMovieMessage>> result = myExecutor.submit(task);
+            results.add(result);
+        }
+        for (Future<ArrayList<LocalMovieMessage>> f : results) {
+            try {
+                movies.addAll(f.get());
+            } catch (Exception ex) {
+                ex.printStackTrace();
+                f.cancel(true);
+            }
+        }
+        myExecutor.shutdown();
+//        for (String fileDir : fileDirs) {
+//            File curFiles = new File(rootPath + fileDir);
+//            if (curFiles.isDirectory()) {
+//                if (callback != null) {
+//                    callback.onMessage(fileDir);
+//                }
+//                String curPath = curFiles.getAbsoluteFile().toString();
+//                LocalMovieMessage moviesItem = new LocalMovieMessage();
+//                String name = NameFilterUtils.getName(fileDir).trim();
+//                moviesItem.setMovieName(name);
+//                String allFirstSpell = PinyinUtil.getAllFirstSpell(name);
+//                String newStr = allFirstSpell.replaceAll("[^\\w,]", "");
+////                Log.d("lovely_pinyin", allFirstSpell + ":" + newStr);
+//                moviesItem.setNamePinyin(newStr);
+//                String media = getMedia(curPath + "/", mediaExtensions);
+//                String poster;
+//                poster = MovieMessageUtils.getLocalMoviePoster(curPath);
+//                if (TextUtils.isEmpty(poster)) {
+//                    poster = getMediaPicture(curPath + "/", picExtensions);
+//                }
+//                if (!TextUtils.isEmpty(poster)) {
+//                    moviesItem.setPosterPath(poster);
+//                }
+//                if (!TextUtils.isEmpty(media)) {
+//                    File mFile = new File(media);
+////                    long length = mFile.length();
+//                    moviesItem.setMd5(MD5Utils.stringMD5(FileHashUtils.getFileHash(media)));
+//                    //read douban id and douban msg,至于name id 信息另外做，没有必要每次更新时都去添加
+//                    try {
+//                        setDoubanMsg(curPath, moviesItem);
+//                    } catch (Exception e) {
+//                        Log.e("otherError", media);
+//                        e.printStackTrace();
+//                    }
+//                    moviesItem.setType(fileDir);
+//                    moviesItem.setPlayPath(media);
+//                    String movieDlTime = String.valueOf(mFile.lastModified());
+//                    moviesItem.setMovieLength(movieDlTime);
+//                    moviesItem.setDlTime(movieDlTime);
+//                    moviesItem.setCount(MovieMessageUtils.getPlayCount(curPath));
+//                    movies.add(moviesItem);
+//                }
+//            }
+//        }
+        return movies;
+    }
+
+    private class ScanTask implements Callable<ArrayList<LocalMovieMessage>> {
+        private String rootPath;
+        private String[] dirs;
+
+        private ScanTask(String rootPath, String[] dirs) {
+            this.rootPath = rootPath;
+            this.dirs = dirs;
+        }
+
+        @Override
+        public ArrayList<LocalMovieMessage> call() throws Exception {
+            ArrayList<LocalMovieMessage> movies = new ArrayList<>();
+            for (String fileDir : dirs) {
+                File curFiles = new File(rootPath + fileDir);
+                if (curFiles.isDirectory()) {
+                    String curPath = curFiles.getAbsoluteFile().toString();
+                    LocalMovieMessage moviesItem = new LocalMovieMessage();
+                    String name = NameFilterUtils.getName(fileDir).trim();
+                    moviesItem.setMovieName(name);
+                    String allFirstSpell = PinyinUtil.getAllFirstSpell(name);
+                    String newStr = allFirstSpell.replaceAll("[^\\w,]", "");
+                    moviesItem.setNamePinyin(newStr);
+                    String media = getMedia(curPath + "/", mediaExtensions);
+                    String poster;
+                    poster = MovieMessageUtils.getLocalMoviePoster(curPath);
+                    if (TextUtils.isEmpty(poster)) {
+                        poster = getMediaPicture(curPath + "/", picExtensions);
+                    }
+                    if (!TextUtils.isEmpty(poster)) {
+                        moviesItem.setPosterPath(poster);
+                    }
+                    if (!TextUtils.isEmpty(media)) {
+                        File mFile = new File(media);
+//                    long length = mFile.length();
+                        moviesItem.setMd5(MD5Utils.stringMD5(FileHashUtils.getFileHash(media)));
+                        //read douban id and douban msg,至于name id 信息另外做，没有必要每次更新时都去添加
+                        try {
+                            setDoubanMsg(curPath, moviesItem);
+                        } catch (Exception e) {
+                            Log.e("otherError", media);
+                            e.printStackTrace();
+                        }
+                        moviesItem.setType(fileDir);
+                        moviesItem.setPlayPath(media);
+                        String movieDlTime = String.valueOf(mFile.lastModified());
+                        moviesItem.setMovieLength(movieDlTime);
+                        moviesItem.setDlTime(movieDlTime);
+                        moviesItem.setCount(MovieMessageUtils.getPlayCount(curPath));
+                        movies.add(moviesItem);
+                        curPath = null;
+                        name = null;
+                        allFirstSpell = null;
+                        newStr = null;
+                        media = null;
+                        poster = null;
+                        movieDlTime = null;
                     }
-//                    SaveMessage saveMessage = new SaveMessage();
-//                    saveMessage.setFile_hash(md5);
-//                    long movieLength = getMovieLength(media);
-//                    int len = (int) (movieLength / 60);
-//                    saveMessage.setLength(len+"");
-//                    result.add(saveMessage);
-                    moviesItem.setType(fileDir);
-                    moviesItem.setPlayPath(media);
-                    String movieDlTime = String.valueOf(mFile.lastModified());
-                    moviesItem.setMovieLength(movieDlTime);
-                    moviesItem.setDlTime(movieDlTime);
-                    moviesItem.setCount(MovieMessageUtils.getPlayCount(curPath));
-                    movies.add(moviesItem);
                 }
             }
+            return movies;
         }
-        return movies;
+    }
+
+    /**
+     * The default thread factory.
+     */
+    private static class MyThreadFactory implements ThreadFactory {
+        private static final AtomicInteger poolNumber = new AtomicInteger(1);
+        private final ThreadGroup group;
+        private final AtomicInteger threadNumber = new AtomicInteger(1);
+        private final String namePrefix;
+
+        MyThreadFactory() {
+            SecurityManager s = System.getSecurityManager();
+            group = (s != null) ? s.getThreadGroup() :
+                    Thread.currentThread().getThreadGroup();
+            namePrefix = "pool-" +
+                    poolNumber.getAndIncrement() +
+                    "-thread-";
+        }
+
+        public Thread newThread(Runnable r) {
+            Thread t = new Thread(group, r,
+                    namePrefix + threadNumber.getAndIncrement(),
+                    0);
+
+            t.setDaemon(true);
+            if (t.getPriority() != Thread.NORM_PRIORITY)
+                t.setPriority(Thread.NORM_PRIORITY);
+            return t;
+        }
+    }
+
+    private synchronized long getDuration(String path) {
+        long in = System.currentTimeMillis();
+        MediaPlayer mMediaPlayer = new MediaPlayer();
+        try {
+            mMediaPlayer.setDataSource(path);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        int duration = mMediaPlayer.getDuration();
+        Log.d("duration", (System.currentTimeMillis() - in) + ":" + duration);
+        return duration;
     }
 
     private long getMovieLength(String mUri) {
@@ -337,6 +471,6 @@ public class LocalMovieScanUtils {
             mmr.release();
         }
         Log.d("getAllType", "" + (System.currentTimeMillis() - l));
-        return duration / 1000;
+        return duration;
     }
 }

@@ -29,21 +29,16 @@ public class QrCodeShowActivity extends Activity implements IUpdateQrCodeView {
     public static final int KILL_SELF = 0x9983;
     private Handler handler = new Handler();
     private QrCodeShowPresent present;
-    Runnable r = new Runnable() {
-        @Override
-        public void run() {
-            closeSystem();
-        }
-    };
+//    Runnable r = new Runnable() {
+//        @Override
+//        public void run() {
+//            closeSystem();
+//        }
+//    };
 
-    private void closeSystem() {
-        LogUtils.i("closeSystem");
-        LightOperationUtils.close();
-        LightOperationUtils.setLightValue(5);
-        new SystemUtils().closeFtLed(QrCodeShowActivity.this.getApplicationContext());
-        present.reportSleepStatus(orderSn, roomSn);
-        QrCodeShowActivity.this.finish();
-    }
+//    private void closeSystem() {
+//
+//    }
 
     private String orderSn;
     private String roomSn;
@@ -54,7 +49,12 @@ public class QrCodeShowActivity extends Activity implements IUpdateQrCodeView {
         public void run() {
             //日志显示，没有结束，以此确保20min后关闭相关
             if (updateCount++ == 2) {
-                closeSystem();
+                LogUtils.i("closeSystem");
+                LightOperationUtils.close();
+                LightOperationUtils.setLightValue(5);
+                new SystemUtils().closeFtLed(QrCodeShowActivity.this.getApplicationContext());
+                present.reportSleepStatus(orderSn, roomSn);
+                QrCodeShowActivity.this.finish();
                 return;
             }
             LogUtils.i("room-info", "QrCodeShowActivity update qr code runnable run");
@@ -72,7 +72,6 @@ public class QrCodeShowActivity extends Activity implements IUpdateQrCodeView {
         orderSn = getIntent().getStringExtra("order_sn");
         roomSn = getIntent().getStringExtra("room_sn");
         iv = (ImageView) findViewById(qrCodeIv);
-        handler.postDelayed(r, 20 * 60 * 1000);
 
         if (!TextUtils.isEmpty(roomSn) && !TextUtils.isEmpty(orderSn)) {
             handler.post(updateQrCodeRunnable);
@@ -89,7 +88,7 @@ public class QrCodeShowActivity extends Activity implements IUpdateQrCodeView {
         } catch (Exception e) {
             e.printStackTrace();
         }
-        handler.removeCallbacks(r);
+        handler.removeCallbacks(updateQrCodeRunnable);
         handler.removeCallbacks(null);
         EventBus.getDefault().unregister(this);
     }
@@ -97,7 +96,7 @@ public class QrCodeShowActivity extends Activity implements IUpdateQrCodeView {
     @Override
     protected void onPause() {
         super.onPause();
-        handler.removeCallbacks(r);
+        handler.removeCallbacks(updateQrCodeRunnable);
         handler.removeCallbacks(null);
     }