File tree Expand file tree Collapse file tree
main/java/com/couchbase/lite/internal/exec
test/java/com/couchbase/lite Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1515//
1616package com .couchbase .lite .internal .exec ;
1717
18- import android .os .Build ;
19-
2018import androidx .annotation .GuardedBy ;
2119import androidx .annotation .NonNull ;
2220import androidx .annotation .Nullable ;
@@ -143,11 +141,7 @@ void finishTask() {
143141 private void executeTask (@ NonNull InstrumentedTask newTask ) {
144142 try {
145143 executor .execute (() -> {
146- if (Build .VERSION .SDK_INT >= Build .VERSION_CODES .BAKLAVA ) {
147- currentThread = Thread .currentThread ().threadId ();
148- } else {
149- currentThread = Thread .currentThread ().getId ();
150- }
144+ currentThread = Thread .currentThread ().getId ();
151145 newTask .run ();
152146 currentThread = -1 ;
153147 });
Original file line number Diff line number Diff line change 1515//
1616package com .couchbase .lite .internal .exec ;
1717
18- import android .os .Build ;
19-
2018import androidx .annotation .GuardedBy ;
2119import androidx .annotation .NonNull ;
2220import androidx .annotation .Nullable ;
@@ -166,11 +164,7 @@ private void executeTask(@Nullable InstrumentedTask prevTask) {
166164 if (nextTask == null ) { return ; }
167165
168166 try { executor .execute (() -> {
169- if (Build .VERSION .SDK_INT >= Build .VERSION_CODES .BAKLAVA ) {
170- currentThread = Thread .currentThread ().threadId ();
171- } else {
172- currentThread = Thread .currentThread ().getId ();
173- }
167+ currentThread = Thread .currentThread ().getId ();
174168 nextTask .run ();
175169 currentThread = -1 ;
176170 }); }
Original file line number Diff line number Diff line change @@ -171,6 +171,7 @@ abstract class BaseDbTest : BaseTest() {
171171 testTg = getUniqueName(" db_test_tag" )
172172
173173 testExec = object : CloseableExecutor {
174+ var currentThread: Long = - 1
174175 val executor: ThreadPoolExecutor = ThreadPoolExecutor (
175176 1 , 1 ,
176177 30 , TimeUnit .SECONDS ,
@@ -196,15 +197,21 @@ abstract class BaseDbTest : BaseTest() {
196197 override fun execute (task : Runnable ) {
197198 Report .log(" task enqueued: %s" , task)
198199 executor.execute {
200+ currentThread = Thread .currentThread().id
199201 Report .log(" Test task started: %s" , task)
200202 try {
201203 task.run ()
202204 } finally {
205+ currentThread = - 1
203206 Report .log(" Test task finished: %s" , task)
204207 }
205208 }
206209 }
207210
211+ override fun isInsideExecutor (): Boolean {
212+ return Thread .currentThread().id == currentThread;
213+ }
214+
208215 override fun getPending (): Int {
209216 return executor.queue.size
210217 }
You can’t perform that action at this time.
0 commit comments