특정 상황에서는 맞춤설정 스레딩 전략을 제공해야 합니다. 예를 들어 콜백 기반의 비동기 작업을 처리해야 하는 경우입니다. 이때는 차단 방식으로 작업을 할 수 없기 때문에 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; }); } }
다른 프로세스에서 ListenableWorker 실행
ListenableWorker
의 구현인 RemoteListenableWorker
를 사용하여 작업자를 특정 프로세스에 바인딩할 수도 있습니다.
RemoteListenableWorker
는 작업 요청을 작성할 때 입력 데이터의 일부로 제공하는 두 개의 추가 인수 ARGUMENT_CLASS_NAME
과 ARGUMENT_PACKAGE_NAME
을 사용하여 특정 프로세스에 바인딩합니다.
다음 예에서는 특정 프로세스에 바인딩된 작업 요청을 빌드하는 방법을 보여줍니다.
Kotlin
val PACKAGE_NAME = "com.example.background.multiprocess" val serviceName = RemoteWorkerService::class.java.name val componentName = ComponentName(PACKAGE_NAME, serviceName) val data: Data = Data.Builder() .putString(ARGUMENT_PACKAGE_NAME, componentName.packageName) .putString(ARGUMENT_CLASS_NAME, componentName.className) .build() return OneTimeWorkRequest.Builder(ExampleRemoteListenableWorker::class.java) .setInputData(data) .build()
자바
String PACKAGE_NAME = "com.example.background.multiprocess"; String serviceName = RemoteWorkerService.class.getName(); ComponentName componentName = new ComponentName(PACKAGE_NAME, serviceName); Data data = new Data.Builder() .putString(ARGUMENT_PACKAGE_NAME, componentName.getPackageName()) .putString(ARGUMENT_CLASS_NAME, componentName.getClassName()) .build(); return new OneTimeWorkRequest.Builder(ExampleRemoteListenableWorker.class) .setInputData(data) .build();
RemoteWorkerService
마다 AndroidManifest.xml
파일에 서비스 정의도 추가해야 합니다.
<manifest ... > <service android:name="androidx.work.multiprocess.RemoteWorkerService" android:exported="false" android:process=":worker1" /> <service android:name=".RemoteWorkerService2" android:exported="false" android:process=":worker2" /> ... </manifest>