Concurrency runInTransaction cause InterruptedException [400584611]

Fixed

Bug

Status Update

No update yet.

Description

ly...@gmail.com

created issue #1

Mar 4, 2025 09:48AM

Component used:room

Version used:2.7.0-rc01

Exception

    Caused by: java.lang.InterruptedException
    	at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:94)
    	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:69)
    	at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source:1)
    	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:47)
    	at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source:1)
    	at androidx.room.util.DBUtil__DBUtil_androidKt.performBlocking(DBUtil.android.kt:69)
    	at androidx.room.util.DBUtil.performBlocking(Unknown Source:1)
    	at XXXDao_Impl.xxxxx(XXXDao_Impl.kt)
    	at androidx.room.RoomDatabase.runInTransaction(RoomDatabase.android.kt:733)

PS, please don't reference my email in comment

Comments

ly...@gmail.com <ly...@gmail.com> #2Mar 5, 2025 01:39AM

This happens when blocking thread interrupted.

Use case: RxJava, When switchMap is upstream, downstream blocking operation will be interrupted.

In older version room, runInTransaction is not interruptible, never throws exception like this.

da...@google.com <da...@google.com> #3Mar 6, 2025 02:41PM

We updated Room internals to Coroutines and one of the improvements is interruption. Before the internal changes, Room would ignore thread interruption, database operations where not really cancellable, but in the latest version and due to Coroutines, Room can be interrupted but since it has to return some value which it couldn't compute it then throws InterruptedException as part of the runBlocking used to bridge blocking DAO functions with Coroutine internals. I think you will need to handle the exception as any other and determine what to return or ignore since Room can't make that decision for you.

ly...@gmail.com <ly...@gmail.com> #4Mar 7, 2025 12:15AM

That's a big change. I think some method should be marked with @Throws(InterruptedException::class) like runBlocking.

ly...@gmail.com <ly...@gmail.com> #5Mar 11, 2025 06:24AM

runBlocking used to bridge blocking DAO functions with Coroutine internals

It seems that all non-suspend DAO query function are throws InterruptedException.

Huge migration.

da...@google.com <da...@google.com> #6Mar 13, 2025 12:39PM

An update: I agree this is a big behavior change and for compatibility reasons we want to continue having Room blocking DAO functions and API be uninterruptible. We are trying to work on a solution for this.

ap...@google.com <ap...@google.com> #7Mar 19, 2025 03:19PM

Project: platform/frameworks/support
Branch: androidx-main
Author: Daniel Santiago Rivera <danysantiago@google.com>
Link: https://android-review.googlesource.com/3539759

Use Coroutines RxJava builders in RxRoom

Expand for full commit details

Use Coroutines RxJava builders in RxRoom 
 
The coroutines-rxjava builders have better handling for cancellation and allows Room to use Coroutine internals more natively which in turns avoids performBlocking. 
 
Bug: 400584611 
Test: RxJava2Test and RxJava3Test 
Change-Id: I639162c82584eea358d061d0e2c48ce0f260a47c

Files:

M room/integration-tests/kotlintestapp/src/androidTest/java/androidx/room/integration/kotlintestapp/test/DeferredBooksDaoTest.kt
M room/integration-tests/kotlintestapp/src/androidTest/java/androidx/room/integration/kotlintestapp/test/RxJava2QueryTest.kt
M room/integration-tests/kotlintestapp/src/androidTest/java/androidx/room/integration/kotlintestapp/test/UpsertTest.kt
M room/integration-tests/testapp/src/androidTest/java/androidx/room/integration/testapp/test/RxJava2Test.java
M room/integration-tests/testapp/src/androidTest/java/androidx/room/integration/testapp/test/RxJava3Test.java
M room/room-rxjava2/src/main/java/androidx/room/RxRoom.kt
M room/room-rxjava3/src/main/java/androidx/room/rxjava3/RxRoom.kt

Hash: 52899e0b7ab58364d7467f39dfee82cc3dc2c04d
Date: Wed Mar 12 11:38:37 2025

ap...@google.com <ap...@google.com> #8Mar 19, 2025 10:17PM

Project: platform/frameworks/support
Branch: androidx-main
Author: Daniel Santiago Rivera <danysantiago@google.com>
Link: https://android-review.googlesource.com/3542279

Use an uninterruptible version of runBlocking

Expand for full commit details

Use an uninterruptible version of runBlocking 
 
As part of Room KMP the internals in Room were migrated to Coroutines and for compatibility reasons blocking functions (APIs and generated code) where migrated to use a bridge that relied on runBlocking. This introduced a behaviour change where if the thread that called runBlocking was interrupted, then runBlocking would throw an InterruptedException. The behaviour in general is not bad since it means work is abandoned faster but it breaks behaviour compatibility as Room never threw this exception before. 
 
To not break existing application and expectations this change adds a runBlockingUninterruptible to be used in Room's bridge that works like runBlocking but ignores thread interruption. 
 
Bug: 342709652 
Bug: 400584611 
Test: RunBlockingUninterruptibleTest 
Change-Id: Ib591225477829e77b51e65a14556d6caddc62222

Files:

A room/integration-tests/kotlintestapp/src/androidTest/java/androidx/room/integration/kotlintestapp/test/InterruptionTest.kt
A room/room-runtime/src/androidInstrumentedTest/kotlin/androidx/room/coroutines/RunBlockingUninterruptibleTest.kt
M room/room-runtime/src/androidMain/kotlin/androidx/room/InvalidationTracker.android.kt
M room/room-runtime/src/androidMain/kotlin/androidx/room/RoomDatabase.android.kt
A room/room-runtime/src/androidMain/kotlin/androidx/room/coroutines/RunBlockingUninterruptible.android.kt
M room/room-runtime/src/androidMain/kotlin/androidx/room/util/DBUtil.android.kt

Hash: e20fec969cc938655537f87624a6f45e942c370d
Date: Thu Mar 13 10:37:44 2025

da...@google.com <da...@google.com> Mar 19, 2025 10:18PM

Marked as fixed.