AsyncTaskLoader onLoadFinished с ожидающей задачей и изменением конфигурации
Я пытаюсь использовать AsyncTaskLoader
для загрузки данных в фоновом режиме для заполнения подробного представления в ответ на выбранный элемент списка. Я получил работу в основном, но у меня все еще есть одна проблема. Если я выберу второй элемент в списке и затем поверните устройство до того, как загрузка для первого выбранного элемента будет завершена, вызов onLoadFinished()
сообщает об остановленном действии, а не о новом действии. Это прекрасно работает при выборе только одного элемента и затем вращении.
Вот код, который я использую. Активность:
public final class DemoActivity extends Activity
implements NumberListFragment.RowTappedListener,
LoaderManager.LoaderCallbacks<String> {
private static final AtomicInteger activityCounter = new AtomicInteger(0);
private int myActivityId;
private ResultFragment resultFragment;
private Integer selectedNumber;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
myActivityId = activityCounter.incrementAndGet();
Log.d("DemoActivity", "onCreate for " + myActivityId);
setContentView(R.layout.demo);
resultFragment = (ResultFragment) getFragmentManager().findFragmentById(R.id.result_fragment);
getLoaderManager().initLoader(0, null, this);
}
@Override
protected void onDestroy() {
super.onDestroy();
Log.d("DemoActivity", "onDestroy for " + myActivityId);
}
@Override
public void onRowTapped(Integer number) {
selectedNumber = number;
resultFragment.setResultText("Fetching details for item " + number + "...");
getLoaderManager().restartLoader(0, null, this);
}
@Override
public Loader<String> onCreateLoader(int id, Bundle args) {
return new ResultLoader(this, selectedNumber);
}
@Override
public void onLoadFinished(Loader<String> loader, String data) {
Log.d("DemoActivity", "onLoadFinished reporting to activity " + myActivityId);
resultFragment.setResultText(data);
}
@Override
public void onLoaderReset(Loader<String> loader) {
}
static final class ResultLoader extends AsyncTaskLoader<String> {
private static final Random random = new Random();
private final Integer number;
private String result;
ResultLoader(Context context, Integer number) {
super(context);
this.number = number;
}
@Override
public String loadInBackground() {
// Simulate expensive Web call
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "Item " + number + " - Price: $" + random.nextInt(500) + ".00, Number in stock: " + random.nextInt(10000);
}
@Override
public void deliverResult(String data) {
if (isReset()) {
// An async query came in while the loader is stopped
return;
}
result = data;
if (isStarted()) {
super.deliverResult(data);
}
}
@Override
protected void onStartLoading() {
if (result != null) {
deliverResult(result);
}
// Only do a load if we have a source to load from
if (number != null) {
forceLoad();
}
}
@Override
protected void onStopLoading() {
// Attempt to cancel the current load task if possible.
cancelLoad();
}
@Override
protected void onReset() {
super.onReset();
// Ensure the loader is stopped
onStopLoading();
result = null;
}
}
}
Список фрагментов:
public final class NumberListFragment extends ListFragment {
interface RowTappedListener {
void onRowTapped(Integer number);
}
private RowTappedListener rowTappedListener;
@Override
public void onAttach(Activity activity) {
super.onAttach(activity);
rowTappedListener = (RowTappedListener) activity;
}
@Override
public void onActivityCreated(Bundle savedInstanceState) {
super.onActivityCreated(savedInstanceState);
ArrayAdapter<Integer> adapter = new ArrayAdapter<Integer>(getActivity(),
R.layout.simple_list_item_1,
Arrays.asList(1, 2, 3, 4, 5, 6));
setListAdapter(adapter);
}
@Override
public void onListItemClick(ListView l, View v, int position, long id) {
ArrayAdapter<Integer> adapter = (ArrayAdapter<Integer>) getListAdapter();
rowTappedListener.onRowTapped(adapter.getItem(position));
}
}
Результат:
public final class ResultFragment extends Fragment {
private TextView resultLabel;
@Override
public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {
View root = inflater.inflate(R.layout.result_fragment, container, false);
resultLabel = (TextView) root.findViewById(R.id.result_label);
if (savedInstanceState != null) {
resultLabel.setText(savedInstanceState.getString("labelText", ""));
}
return root;
}
@Override
public void onSaveInstanceState(Bundle outState) {
super.onSaveInstanceState(outState);
outState.putString("labelText", resultLabel.getText().toString());
}
void setResultText(String resultText) {
resultLabel.setText(resultText);
}
}
Мне удалось получить эту работу, используя простой AsyncTask
, но я пытаюсь узнать больше о Loader
, так как они автоматически обрабатывают изменения конфигурации.
РЕДАКТИРОВАТЬ. Я думаю, что, возможно, я выяснил эту проблему, посмотрев источник LoaderManager. Когда после изменения конфигурации вызывается initLoader
, объект LoaderInfo
имеет поле mCallbacks
, обновленное с новым действием, как реализация LoaderCallbacks
, как и следовало ожидать.
public <D> Loader<D> initLoader(int id, Bundle args, LoaderManager.LoaderCallbacks<D> callback) {
if (mCreatingLoader) {
throw new IllegalStateException("Called while creating a loader");
}
LoaderInfo info = mLoaders.get(id);
if (DEBUG) Log.v(TAG, "initLoader in " + this + ": args=" + args);
if (info == null) {
// Loader doesn't already exist; create.
info = createAndInstallLoader(id, args, (LoaderManager.LoaderCallbacks<Object>)callback);
if (DEBUG) Log.v(TAG, " Created new loader " + info);
} else {
if (DEBUG) Log.v(TAG, " Re-using existing loader " + info);
info.mCallbacks = (LoaderManager.LoaderCallbacks<Object>)callback;
}
if (info.mHaveData && mStarted) {
// If the loader has already generated its data, report it now.
info.callOnLoadFinished(info.mLoader, info.mData);
}
return (Loader<D>)info.mLoader;
}
Однако, когда есть ожидающий загрузчик, основной объект LoaderInfo
также имеет поле mPendingLoader
со ссылкой на LoaderCallbacks
, и этот объект никогда не обновляется новым действием в mCallbacks
. Я бы ожидал увидеть, что код выглядит так:
// This line was already there
info.mCallbacks = (LoaderManager.LoaderCallbacks<Object>)callback;
// This line is not currently there
info.mPendingLoader.mCallbacks = (LoaderManager.LoaderCallbacks<Object>)callback;
Похоже, из-за этого ожидающий загрузчик вызывает onLoadFinished
в старом экземпляре активности. Если я останусь в этом методе и сделаю вызов, который, как мне кажется, отсутствует с помощью отладчика, все работает так, как я ожидаю.
Новый вопрос: я нашел ошибку или это ожидаемое поведение?
Ответы
Ответ 1
В большинстве случаев вам следует просто игнорировать такие отчеты, если активность уже уничтожена.
public void onLoadFinished(Loader<String> loader, String data) {
Log.d("DemoActivity", "onLoadFinished reporting to activity " + myActivityId);
if (isDestroyed()) {
Log.i("DemoActivity", "Activity already destroyed, report ignored: " + data);
return;
}
resultFragment.setResultText(data);
}
Также вы должны вставить проверку isDestroyed()
в любые внутренние классы. Runnable - наиболее часто используемый случай.
Например:
// UI thread
final Handler handler = new Handler();
Executor someExecutorService = ... ;
someExecutorService.execute(new Runnable() {
public void run() {
// some heavy operations
...
// notification to UI thread
handler.post(new Runnable() {
// this runnable can link to 'dead' activity or any outer instance
if (isDestroyed()) {
return;
}
// we are alive
onSomeHeavyOperationFinished();
});
}
});
Но в таких случаях лучший способ - не передавать сильную ссылку на Activity в другой поток (AsynkTask, Loader, Executor и т.д.).
Самое надежное решение здесь:
// BackgroundExecutor.java
public class BackgroundExecutor {
private static final Executor instance = Executors.newSingleThreadExecutor();
public static void execute(Runnable command) {
instance.execute(command);
}
}
// MyActivity.java
public class MyActivity extends Activity {
// Some callback method from any button you want
public void onSomeButtonClicked() {
// Show toast or progress bar if needed
// Start your heavy operation
BackgroundExecutor.execute(new SomeHeavyOperation(this));
}
public void onSomeHeavyOperationFinished() {
if (isDestroyed()) {
return;
}
// Hide progress bar, update UI
}
}
// SomeHeavyOperation.java
public class SomeHeavyOperation implements Runnable {
private final WeakReference<MyActivity> ref;
public SomeHeavyOperation(MyActivity owner) {
// Unlike inner class we do not store strong reference to Activity here
this.ref = new WeakReference<MyActivity>(owner);
}
public void run() {
// Perform your heavy operation
// ...
// Done!
// It time to notify Activity
final MyActivity owner = ref.get();
// Already died reference
if (owner == null) return;
// Perform notification in UI thread
owner.runOnUiThread(new Runnable() {
public void run() {
owner.onSomeHeavyOperationFinished();
}
});
}
}
Ответ 2
Возможно, не лучшее решение, но...
Этот загрузчик перезапуска кода каждый раз, что плохо, но работает только с этим - если вы хотите использовать загрузчик.
Loader l = getLoaderManager().getLoader(MY_LOADER);
if (l != null) {
getLoaderManager().restartLoader(MY_LOADER, null, this);
} else {
getLoaderManager().initLoader(MY_LOADER, null, this);
}
BTW. Я использую Cursorloader...
Ответ 3
Возможное решение заключается в том, чтобы запустить AsyncTask в пользовательском одноэлементном объекте и получить доступ к результату onFinished() из singleton внутри вашей Activity. Каждый раз, когда вы поворачиваете экран, переходите в onPause() или onResume(), последний результат будет использоваться/доступен. Если у вас все еще нет результата в вашем одноэлементном объекте, вы знаете, что он все еще занят или что вы можете перезапустить задачу.
Другой подход - работать с служебной шиной, например Отто, или работать с Сервисом.
Ответ 4
Хорошо. Я пытаюсь понять это извините, если я что-то не понял, но вы теряете ссылки на что-то, когда устройство вращается.
Принимая удар...
добавит
android:configChanges="orientation|keyboardHidden|screenSize"
в вашем манифесте для этого действия исправить вашу ошибку? или запретить onLoadFinished()
заявить, что активность остановлена?