Доступ к базе данных из AsyncTask и Activity - блокировки.Решение? - PullRequest
Новая
       14

Доступ к базе данных из AsyncTask и Activity - блокировки.Решение?

2 голосов
/ 16 июня 2011

У меня есть приложение для Android, которое общается с сервером и синхронизирует некоторые данные в базе данных SQLite.Существует служба, которая запускается каждые 5 минут и охватывает AsyncTask, которая захватывает данные и вставляет / обновляет данные в базе данных.

Вот моя проблема.Когда фоновый процесс обновляет базу данных, это может занять значительное время.Если пользователь пытается одновременно использовать приложение и открывает ListView с курсором, привязанным к той же таблице, я получаю тупиковую ситуацию и отчет ANR.

Как правильно решить эту проблему?

IЧУВСТВУЙТЕ, будто мне нужно проверить из пользовательского интерфейса, работает ли asyncprocess (как?), И если да, то показать пользователю, что происходит фоновое обновление, и загрузить список, как только процесс, обращающийся к данным, завершит работу в фоновом режиме.

Какой правильный способрешить эту проблему?

РЕДАКТИРОВАТЬ

Вот отчет 

DALVIK THREADS:
"main" prio=5 tid=1 WAIT
  | group="main" sCount=1 dsCount=0 s=N obj=0x2aac88b8 self=0xcd58
  | sysTid=3967 nice=0 sched=0/0 cgrp=unknown handle=1876207664
  at java.lang.Object.wait(Native Method)
  - waiting on <0x2aac8948> (a java.lang.VMThread)
  at java.lang.Thread.parkFor(Thread.java:1535)
  at java.lang.LangAccessImpl.parkFor(LangAccessImpl.java:48)
  at sun.misc.Unsafe.park(Unsafe.java:317)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:131)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:790)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:823)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1153)
  at java.util.concurrent.locks.ReentrantLock$FairSync.lock(ReentrantLock.java:200)
  at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:261)
  at android.database.sqlite.SQLiteDatabase.lock(SQLiteDatabase.java:375)
  at android.database.sqlite.SQLiteQuery.fillWindow(SQLiteQuery.java:61)
  at android.database.sqlite.SQLiteCursor.fillWindow(SQLiteCursor.java:283)
  at android.database.sqlite.SQLiteCursor.getCount(SQLiteCursor.java:264)
  at android.content.ContentResolver.query(ContentResolver.java:251)
  ****************at com.idatt.data.PreferenceData.getPreferenceString(PreferenceData.java:119)
  at com.idatt.data.PreferenceData.getPreferenceBoolean(PreferenceData.java:109)
  at com.idatt.common.Preferences.getIsShowRates(Preferences.java:136)
  at com.idatt.activities.TripListActivity$TripViewDataHolder.populateFrom(TripListActivity.java:211)
  at com.idatt.activities.TripListActivity$TripListCursorAdapter.getView(TripListActivity.java:147)
  at android.widget.AbsListView.obtainView(AbsListView.java:1294)
  at android.widget.ListView.measureHeightOfChildren(ListView.java:1198)
  at android.widget.ListView.onMeasure(ListView.java:1109)
  at android.view.View.measure(View.java:8187)
  at android.view.ViewGroup.measureChildWithMargins(ViewGroup.java:3146)
  at android.widget.LinearLayout.measureChildBeforeLayout(LinearLayout.java:1012)
  at android.widget.LinearLayout.measureVertical(LinearLayout.java:381)
  at android.widget.LinearLayout.onMeasure(LinearLayout.java:304)
  at android.view.View.measure(View.java:8187)
  at android.view.ViewGroup.measureChildWithMargins(ViewGroup.java:3146)
  at android.widget.LinearLayout.measureChildBeforeLayout(LinearLayout.java:1012)
  at android.widget.LinearLayout.measureVertical(LinearLayout.java:381)
  at android.widget.LinearLayout.onMeasure(LinearLayout.java:304)
  at android.view.View.measure(View.java:8187)
  at android.view.ViewGroup.measureChildWithMargins(ViewGroup.java:3146)
  at android.widget.FrameLayout.onMeasure(FrameLayout.java:245)
  at android.view.View.measure(View.java:8187)
  at android.view.ViewGroup.measureChildWithMargins(ViewGroup.java:3146)
  at android.widget.FrameLayout.onMeasure(FrameLayout.java:245)
  at android.view.View.measure(View.java:8187)
  at android.view.ViewRoot.performTraversals(ViewRoot.java:801)
  at android.view.ViewRoot.handleMessage(ViewRoot.java:1727)
  at android.os.Handler.dispatchMessage(Handler.java:99)
  at android.os.Looper.loop(Looper.java:123)
  at android.app.ActivityThread.main(ActivityThread.java:4644)
  at java.lang.reflect.Method.invokeNative(Native Method)
  at java.lang.reflect.Method.invoke(Method.java:521)
  at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:878)
  at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:636)
  at dalvik.system.NativeStart.main(Native Method)

"Binder Thread #3" prio=5 tid=14 NATIVE
  | group="main" sCount=1 dsCount=0 s=N obj=0x3033f218 self=0x2394d0
  | sysTid=4305 nice=0 sched=0/0 cgrp=unknown handle=2332488
  at dalvik.system.NativeStart.run(Native Method)

"AsyncTask #5" prio=5 tid=13 WAIT
  | group="main" sCount=1 dsCount=0 s=N obj=0x300dc038 self=0x25f0e0
  | sysTid=4073 nice=10 sched=0/0 cgrp=unknown handle=2965040
  at java.lang.Object.wait(Native Method)
  - waiting on <0x3013c610> (a java.lang.VMThread)
  at java.lang.Thread.parkFor(Thread.java:1535)
  at java.lang.LangAccessImpl.parkFor(LangAccessImpl.java:48)
  at sun.misc.Unsafe.park(Unsafe.java:317)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:131)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:790)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:823)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1153)
  at java.util.concurrent.locks.ReentrantLock$FairSync.lock(ReentrantLock.java:200)
  at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:261)
  at android.database.sqlite.SQLiteDatabase.lock(SQLiteDatabase.java:375)
  at android.database.sqlite.SQLiteDatabase.insertWithOnConflict(SQLiteDatabase.java:1533)
  at android.database.sqlite.SQLiteDatabase.insert(SQLiteDatabase.java:1410)
  at com.idatt.data.Provider.insert(Provider.java:198)
  at android.content.ContentProvider$Transport.insert(ContentProvider.java:174)
  at android.content.ContentResolver.insert(ContentResolver.java:587)
  *************at com.idatt.data.TripData.InsertTrip(TripData.java:272)
  at com.idatt.common.AsyncProcessor.GetUserTrips(AsyncProcessor.java:252)
  at com.idatt.common.AsyncProcessor.doInBackground(AsyncProcessor.java:101)
  at com.idatt.common.AsyncProcessor.doInBackground(AsyncProcessor.java:27)
  at android.os.AsyncTask$2.call(AsyncTask.java:185)
  at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:305)
  at java.util.concurrent.FutureTask.run(FutureTask.java:137)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1068)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:561)
  at java.lang.Thread.run(Thread.java:1096)

"AsyncTask #4" prio=5 tid=12 WAIT
  | group="main" sCount=1 dsCount=0 s=N obj=0x302ffd28 self=0x4e8f30
  | sysTid=4072 nice=10 sched=0/0 cgrp=unknown handle=5163584
  at java.lang.Object.wait(Native Method)
  - waiting on <0x302ffbd8> (a java.lang.VMThread)
  at java.lang.Thread.parkFor(Thread.java:1535)
  at java.lang.LangAccessImpl.parkFor(LangAccessImpl.java:48)
  at sun.misc.Unsafe.park(Unsafe.java:317)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:131)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:790)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:823)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1153)
  at java.util.concurrent.locks.ReentrantLock$FairSync.lock(ReentrantLock.java:200)
  at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:261)
  at android.database.sqlite.SQLiteDatabase.lock(SQLiteDatabase.java:375)
  at android.database.sqlite.SQLiteProgram.close(SQLiteProgram.java:291)
  at android.database.sqlite.SQLiteQuery.close(SQLiteQuery.java:133)
  at android.database.sqlite.SQLiteCursor.close(SQLiteCursor.java:502)
  at android.database.CursorWrapper.close(CursorWrapper.java:45)
  at android.content.ContentResolver$CursorWrapperInner.close(ContentResolver.java:1355)
  ************at com.idatt.data.LogData.getLogItems(LogData.java:118)
  at com.idatt.data.LogData.getLogItems(LogData.java:125)
  at com.idatt.common.AsyncProcessor.PostDeviceLogs(AsyncProcessor.java:210)
  at com.idatt.common.AsyncProcessor.doInBackground(AsyncProcessor.java:96)
  at com.idatt.common.AsyncProcessor.doInBackground(AsyncProcessor.java:27)
  at android.os.AsyncTask$2.call(AsyncTask.java:185)
  at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:305)
  at java.util.concurrent.FutureTask.run(FutureTask.java:137)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1068)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:561)
  at java.lang.Thread.run(Thread.java:1096)

"AsyncTask #3" prio=5 tid=11 WAIT
  | group="main" sCount=1 dsCount=0 s=N obj=0x302ec858 self=0x4ff440
  | sysTid=4071 nice=10 sched=0/0 cgrp=unknown handle=2984848
  at java.lang.Object.wait(Native Method)
  - waiting on <0x302ec9b0> (a java.lang.VMThread)
  at java.lang.Thread.parkFor(Thread.java:1535)
  at java.lang.LangAccessImpl.parkFor(LangAccessImpl.java:48)
  at sun.misc.Unsafe.park(Unsafe.java:317)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:131)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1996)
  at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:359)
  at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1001)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1061)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:561)
  at java.lang.Thread.run(Thread.java:1096)

"AsyncTask #2" prio=5 tid=10 WAIT
  | group="main" sCount=1 dsCount=0 s=N obj=0x302c31a8 self=0x4dca78
  | sysTid=4062 nice=10 sched=0/0 cgrp=unknown handle=5111608
  at java.lang.Object.wait(Native Method)
  - waiting on <0x3027ab38> (a java.lang.VMThread)
  at java.lang.Thread.parkFor(Thread.java:1535)
  at java.lang.LangAccessImpl.parkFor(LangAccessImpl.java:48)
  at sun.misc.Unsafe.park(Unsafe.java:317)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:131)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:790)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:823)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1153)
  at java.util.concurrent.locks.ReentrantLock$FairSync.lock(ReentrantLock.java:200)
  at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:261)
  at android.database.sqlite.SQLiteDatabase....

См. след прилагается.Проверьте строки, которые я пометил ** Я не очень разбираюсь в этом, но вот мои выводы .. Кажется, что он блокируется при попытке выполнить

com.idatt.data.PreferenceData.getPreferenceString

Этот вызов открывает БД в режиме только для чтения (он проходит через мой COntentProvider).И этот вызов происходит в потоке пользовательского интерфейса.

Что плохо - я заметил 2 других вызова: InsertTrips и getLogData .InsertTrips попадает в базу данных, но getLogData также должна быть доступна только для чтения.Тем не менее, они оба являются частью одного AsyncTask.Таким образом, кажется, что один экземпляр AsyncTask был создан из службы / тревоги (каждые 5 минут), а второй экземпляр был создан пользователем (я даю им возможность обновить вручную).

Ситуация выглядит следующим образом:

  • Приложение обновляется по расписанию
  • Пользователь использует приложение и обновляет вызовы вручную
  • После того, как пользователь инициировал обновление вручную -она пытается использовать приложение, где оно обращается к тем же данным ..

Ответы [ 2 ]

1 голос
/ 16 июня 2011

Блокируется ли при использовании таблицы, используемой для получения курсора для списка, или блокируется при доступе к базе данных.Если блокировка основана на таблицах, вы можете рассмотреть возможность использования двух таблиц: для службы и одной для представления, или двух таблиц, и вы переключаетесь на одну для отображения и используете другую для заполнения данных ...

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

С уважением, Стефан

0 голосов
/ 16 июня 2011

Если вы используете AsyncTask правильно, он не должен блокировать ваш поток пользовательского интерфейса.Без кода трудно сказать, что здесь происходит не так.Несколько вещей для проверки:

  • Убедитесь, что вы все вызываете AsyncTask.execute (), а теперь AsyncTask.doInBackground ().Вызов doInBackground () напрямую запустит этот код в потоке пользовательского интерфейса.

  • Вы вручную синхронизируете какой-либо объект, заблокированный во время обновления?

...