특정 상황에서는 맞춤설정 스레딩 전략을 제공해야 합니다. 예를 들어 콜백 기반의 비동기 작업을 처리해야 하는 경우입니다. 이때는 차단 방식으로 작업을 할 수 없기 때문에 Worker
를 사용할 수 없습니다. WorkManager는 ListenableWorker
를 통해 이 사용 사례를 지원합니다. ListenableWorker
는 가장 기본적인 작업자 API입니다. Worker
, CoroutineWorker
, RxWorker
모두 이 클래스에서 파생됩니다. ListenableWorker
는 작업을 시작하고 중지해야 할 때만 신호를 보내고 스레딩을 전적으로 개발자에게 맡깁니다. 작업 시작 신호는 기본 스레드에서 호출되므로 개발자가 직접 선택한 백그라운드 스레드로 반드시 이동해야 합니다.
추상 메서드 ListenableWorker.startWork()
는 Result
의 ListenableFuture
를 반환합니다. ListenableFuture
는 가벼운 인터페이스로, 리스너를 연결하고 예외를 전파하는 기능을 제공하는 Future
입니다. startWork
메서드에서는 개발자가 ListenableFuture
를 반환하도록 요구되며 작업이 완료되면 이를 작업 Result
로 설정하게 됩니다. 다음 두 가지 방법 중 하나로 ListenableFuture
인스턴스를 만들 수 있습니다.
- Guava를 사용한다면
ListeningExecutorService
를 사용합니다. - 그러지 않은 경우 gradle 파일에
councurrent-futures
를 포함하고CallbackToFutureAdapter
를 사용합니다.
비동기 콜백을 기반으로 하여 작업을 실행하려면 다음과 같이 해야 합니다.
Kotlin
class CallbackWorker( context: Context, params: WorkerParameters ) : ListenableWorker(context, params) { override fun startWork(): ListenableFuture<Result> { return CallbackToFutureAdapter.getFuture { completer -> val callback = object : Callback { var successes = 0 override fun onFailure(call: Call, e: IOException) { completer.setException(e) } override fun onResponse(call: Call, response: Response) { successes++ if (successes == 100) { completer.set(Result.success()) } } } repeat(100) { downloadAsynchronously("https://example.com", callback) } callback } } }
자바
public class CallbackWorker extends ListenableWorker { public CallbackWorker(Context context, WorkerParameters params) { super(context, params); } @NonNull @Override public ListenableFuture<Result> startWork() { return CallbackToFutureAdapter.getFuture(completer -> { Callback callback = new Callback() { int successes = 0; @Override public void onFailure(Call call, IOException e) { completer.setException(e); } @Override public void onResponse(Call call, Response response) { successes++; if (successes == 100) { completer.set(Result.success()); } } }; for (int i = 0; i < 100; i++) { downloadAsynchronously("https://www.example.com", callback); } return callback; }); } }
작업이 중지되면 어떻게 되나요? 작업이 중지될 것으로 예상되면 ListenableWorker
의 ListenableFuture
는 항상 취소됩니다. CallbackToFutureAdapter
를 사용하면 다음과 같이 간단히 취소 리스너를 추가하면 됩니다.
Kotlin
class CallbackWorker( context: Context, params: WorkerParameters ) : ListenableWorker(context, params) { override fun startWork(): ListenableFuture<Result> { return CallbackToFutureAdapter.getFuture { completer -> val callback = object : Callback { var successes = 0 override fun onFailure(call: Call, e: IOException) { completer.setException(e) } override fun onResponse(call: Call, response: Response) { ++successes if (successes == 100) { completer.set(Result.success()) } } } completer.addCancellationListener(cancelDownloadsRunnable, executor) repeat(100) { downloadAsynchronously("https://example.com", callback) } callback } } }
자바
public class CallbackWorker extends ListenableWorker { public CallbackWorker(Context context, WorkerParameters params) { super(context, params); } @NonNull @Override public ListenableFuture<Result> startWork() { return CallbackToFutureAdapter.getFuture(completer -> { Callback callback = new Callback() { int successes = 0; @Override public void onFailure(Call call, IOException e) { completer.setException(e); } @Override public void onResponse(Call call, Response response) { ++successes; if (successes == 100) { completer.set(Result.success()); } } }; completer.addCancellationListener(cancelDownloadsRunnable, executor); for (int i = 0; i < 100; ++i) { downloadAsynchronously("https://www.example.com", callback); } return callback; }); } }