특정 상황에서는 맞춤설정 스레딩 전략을 제공해야 합니다. 예를 들어 콜백 기반의 비동기 작업을 처리해야 하는 경우입니다. 이때는 차단 방식으로 작업을 할 수 없기 때문에 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>