Как получить обратный вызов от исполнителя Threadpool для завершения JobService - PullRequest
Новая
       6

Как получить обратный вызов от исполнителя Threadpool для завершения JobService

0 голосов
/ 21 ноября 2018

Мой сценарий заключается в том, что мне нужно загружать 30 zip-файлов каждые 3 МБ и разархивировать все загруженные файлы при первом входе пользователя в систему.Согласно фоновому ограничению OREO, сейчас я планирую работу для выполнения этой задачи.Но проблема здесь в том, что если я загружаю все zip-файлы последовательно, это занимает время.Мне нужно, чтобы эта задача выполнялась параллельно в фоновом режиме, для которого я использую пул потоков для запуска потока.Но как только я использую Executor пула потоков, я не смог понять, как остановить свою работу.Как я могу получить обратный звонок о том, что все zip-файлы были загружены.Является ли планирование заданий правильным способом работы в фоновом режиме или мне следует использовать Диспетчер работ? Мне нужно, чтобы это задание было гарантированно выполнено до конца?

ниже - класс исполнителя пула потоков: 

import android.os.Handler;
import android.os.Looper;
import android.os.Message;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class MyThreadPoolExecutor {
    private static MyThreadPoolExecutor MyThreadPoolExecutor;
    private static int NUMBER_OF_CORES = Runtime.getRuntime().availableProcessors();
    private static final TimeUnit KEEP_ALIVE_TIME_UNIT;
    private final BlockingQueue<Runnable> mDownloadWorkQueue;
    private final ThreadPoolExecutor mDownloadThreadPool;
    private static final int CORE_POOL_SIZE = 8;
    private static final int MAXIMUM_POOL_SIZE = 8;
    private static final int KEEP_ALIVE_TIME = 1;
    private Handler mHandler;

    // A static block that sets class fields
    static {

        // The time unit for "keep alive" is in seconds
        KEEP_ALIVE_TIME_UNIT = TimeUnit.SECONDS;

        // Creates a single static instance of PhotoManager
        MyThreadPoolExecutor = new MyThreadPoolExecutor();
    }

    private MyThreadPoolExecutor() {

        mDownloadWorkQueue = new LinkedBlockingQueue<Runnable>();

        mDownloadThreadPool = new ThreadPoolExecutor(NUMBER_OF_CORES * 2, NUMBER_OF_CORES * 2,
                KEEP_ALIVE_TIME, KEEP_ALIVE_TIME_UNIT, mDownloadWorkQueue);

        mHandler = new Handler(Looper.getMainLooper()) {

            /*
             * handleMessage() defines the operations to perform when the
             * Handler receives a new Message to process.
             */
            @Override
            public void handleMessage(Message inputMessage) {

            }
        };
    }


    public static MyThreadPoolExecutor getInstance() {
        return MyThreadPoolExecutor;
    }


    public void addThread(Runnable runnable){
        mDownloadWorkQueue.add(runnable);
    }

    public void execute(Runnable runnable){
            MyThreadPoolExecutor.mDownloadThreadPool.execute(runnable);

    }


}

ниже - мой исполняемый код: 

public class SimpleThread implements Runnable {
    private String file_url;

    public SimpleThread( String url) {
        this.file_url = url;
    }

    @Override
    public void run() {
        try{

            URL url = new URL(file_url.replaceAll(" ", "%20"));
            InputStream fileInputStream = url.openStream();
            if(fileInputStream != null) {
                lessonmediaSaver.save(fileInputStream);
                String source = "path";
                String destination = "destinationpath";
                 new UnzipUtility().unzip(source,destination);

                System.out.println("Saving Zip --> ");
            }else{
                System.out.println("Zip not saved --> ");

            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

вот как я выполняю свой код службы заданий: 

for(MyObject myObject:myObjectArray){
                        SimpleThread simpleThread = new SimpleThread(myObject.getFileUrl());
                        IstarThreadPoolExecutor.getInstance().execute(simpleThread);
                    }
...