Как поставить в очередь несколько задач в службе переднего плана, чтобы они выполнялись одна за другой? - PullRequest
Новая
       44

Как поставить в очередь несколько задач в службе переднего плана, чтобы они выполнялись одна за другой?

0 голосов
/ 20 апреля 2019 
public class CopyService extends Service {

private List<CustomFile> taskList;
private AsyncTask fileTask;

@Override
public void onCreate() {
    super.onCreate();
    taskList = new ArrayList<>();
    fileTask = new fileTaskAsync();
}

@Override
public int onStartCommand(Intent intent, int flags, int startId) {

    String filePath = intent.getStringExtra("filePath");
    String fileType = intent.getStringExtra("fileType");
    String taskType = intent.getStringExtra("taskType");
    String fileName = intent.getStringExtra("fileName");

    CustomFile customFile = new CustomFile();
    customFile.filePath = filePath;
    customFile.fileType = fileType;
    customFile.taskType = taskType;
    customFile.fileName = fileName;
    taskList.add(customFile);

    Notification notification = getNotification();

    startForeground(787, notification);

    if (fileTask.getStatus() != AsyncTask.Status.RUNNING) {

        CustomFile current = taskList.get(0);
        taskList.remove(current);

        fileTask = new fileTaskAsync().execute(current);
    }

    stopSelf();
    return START_NOT_STICKY;
}

@Nullable
@Override
public IBinder onBind(Intent intent) {
    return null;
}

private class fileTaskAsync extends AsyncTask<CustomFile, Void, String> {

    @Override
    protected String doInBackground(CustomFile... customFiles) {

        CustomFile customFile = customFiles[0];

        FileUtils.doFileTask(customFile.filePath, customFile.fileType,
                customFile.taskType);

        return customFile.fileName;
    }

    @Override
    protected void onPostExecute(String name) {
        sendResult(name);

        if (!taskList.isEmpty()) {
            CustomFile newCurrent = taskList.get(0);
            taskList.remove(newCurrent);
            fileTask = new fileTaskAsync().execute(newCurrent);
        }
    }
}

private void sendResult(String name) {
    Intent intent = new Intent("taskStatus");
    intent.putExtra("taskName", name);
    LocalBroadcastManager.getInstance(this).sendBroadcast(intent);
}

}

Мне нужно выполнить несколько задач в сервисе одну за другой.Задача - копирование или перемещение локальных файлов.Предположим, пользователь копирует большой файл и хочет скопировать или переместить другие файлы.Мне нужно, чтобы последующие задачи ставились в очередь и выполнялись одна за другой.

В настоящее время я создаю список внутри службы и запускаю асинхронную задачу.В onPostExecute я проверяю оставшиеся задачи в списке и снова запускаю асинхронную задачу.Как показано в коде.

Но меня беспокоят утечки памяти.И я очень новичок в программировании, поэтому я не знаю, что лучше всего делать в таких ситуациях.

Я не могу использовать IntentService, потому что я хочу, чтобы задача продолжалась, даже если пользователь нажимает кнопку «Домой»открыть другое приложение.

1 Ответ

1 голос
/ 21 апреля 2019

Как я уже сказал в комментариях, я думаю, что ваше решение является разумным.Foreground Service является хорошим кандидатом для длительной работы, которая должна быть выполнена немедленно, и из вашего описания ваша задача копирования файлов соответствует этому критерию.

Тем не менее, я не верю, что AsyncTaskхороший кандидат на вашу проблему.AsyncTasks лучше всего развертывать, когда вам нужно выполнить некоторую быструю работу вне основного потока, порядка нескольких сотен миллисекунд, в то время как ваша задача копирования может занять несколько секунд.

Поскольку у вас есть несколько задач дляcomplete, которые напрямую не зависят друг от друга, я бы порекомендовал вам использовать пул потоков для выполнения этой работы.Для этого вы можете использовать ExecutorService: 

public class CopyService extends Service {

private final Deque<CustomFile> tasks = new ArrayDeque<>();
private final Deque<Future<?>> futures = new LinkedBlockingDequeue<>();
private final ExecutorService executor = Executors.newCachedThreadPool();

@Override
public int onStartCommand(Intent intent, int flags, int startId) {

    //May as well add a factory method to your CustomFile that creates one from an Intent
    CustomFile customFile = CustomFile.fromIntent(intent);
    tasks.offer(customFile);

    //...Add any other tasks to this queue...

    Notification notification = getNotification();

    startForeground(787, notification);

    for(CustomFile file : tasks) {
       final Future<?> future = executor.submit(new Runnable() {
           @Override
           public void run() {
               final CustomFile file = tasks.poll();
               //Ddo work with the file...
               LocalBroadcastManager.getInstance(CopyService.this).sendBroadcast(...);
               //Check to see whether we've now executed all tasks. If we have, kill the Service.
               if(tasks.isEmpty()) stopSelf();
           }
       });
       futures.offer(future);
    }
    return START_NOT_STICKY;
}

@Override
public void onDestroy() {
    super.onDestroy();
    //Clear pending and active work if the Service is being shutdown
    //You may want to think about whether you want to reschedule any work here too
    for(Future<?> future : futures) {
        if(!future.isDone() && !future.isCancelled()) {
            future.cancel(true); //May pass "false" here. Terminating work immediately may produce side effects.
        } 
    }
}

@Nullable
@Override
public IBinder onBind(Intent intent) {
    return null;
}

Это не должно вызывать утечек памяти, так как любая ожидающая работа уничтожается вместе со службой.

...