Replace most runBlocking calls with runTest in `paging-common` by veyndan · Pull Request #555 · androidx/androidx

veyndan · 2023-06-01T21:43:31Z

The below test is the only remaining instance of runBlocking in paging-common. The rest of the test uses a lot of Java specific stuff, and in Multiplatform Paging, I hadn't attempted to multiplatformize it yet.

androidx/paging/paging-common/src/test/kotlin/androidx/paging/SingleRunnerTest.kt

Lines 151 to 190 in 88877d7

    
           @OptIn(DelicateCoroutinesApi::class) 
        
           @Test 
        
           fun ensureIsolation_whenCancelationIsIgnoredByThePreviousBlock() { 
        
               // make sure we wait for previous one if it ignores cancellation 
        
               val singleRunner = SingleRunner() 
        
               val output = Collections.synchronizedList(mutableListOf<Int>()) 
        
               // using a latch instead of a mutex to avoid suspension 
        
               val firstStarted = CountDownLatch(1) 
        
               GlobalScope.launch { 
        
                   singleRunner.runInIsolation { 
        
                       // this code uses latches and thread sleeps instead of Mutex and delay to mimic 
        
                       // a code path which ignores coroutine cancellation 
        
                       firstStarted.countDown() 
        
                       repeat(10) { 
        
                           @Suppress("BlockingMethodInNonBlockingContext") 
        
                           Thread.sleep(100) 
        
                           output.add(it) 
        
                       } 
        
                   } 
        
               } 
        
               val job2 = GlobalScope.launch { 
        
                   @Suppress("BlockingMethodInNonBlockingContext") 
        
                   firstStarted.await() 
        
                   singleRunner.runInIsolation { 
        
                       repeat(10) { 
        
                           output.add(it + 10) 
        
                       } 
        
                   } 
        
               } 
        
               runBlocking { 
        
                   withTimeout(10.seconds) { 
        
                       job2.join() 
        
                   } 
        
               } 
        
               assertThat(output).isEqualTo( 
        
                   // if cancellation is ignored, make sure we wait for it to finish. 
        
                   (0 until 20).toList() 
        
               ) 
        
           }

Test: ./gradlew test connectedCheck
Bug: 270612487

claraf3 self-requested a review June 1, 2023 22:29

claraf3 approved these changes Jun 2, 2023

View reviewed changes

Replace most runBlocking calls with runTest

4749aac

veyndan force-pushed the 270612487/replace-runBlocking-with-runTest branch from 297bcb9 to 4749aac Compare June 2, 2023 21:50

copybara-service bot closed this in 143a6f5 Jun 2, 2023

veyndan deleted the 270612487/replace-runBlocking-with-runTest branch June 3, 2023 21:32

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Replace most runBlocking calls with runTest in `paging-common`#555

Replace most runBlocking calls with runTest in `paging-common`#555
veyndan wants to merge 1 commit intoandroidx:androidx-mainfrom
veyndan:270612487/replace-runBlocking-with-runTest

veyndan commented Jun 1, 2023

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants

	@OptIn(DelicateCoroutinesApi::class)
	@Test
	fun ensureIsolation_whenCancelationIsIgnoredByThePreviousBlock() {
	// make sure we wait for previous one if it ignores cancellation
	val singleRunner = SingleRunner()
	val output = Collections.synchronizedList(mutableListOf<Int>())
	// using a latch instead of a mutex to avoid suspension
	val firstStarted = CountDownLatch(1)
	GlobalScope.launch {
	singleRunner.runInIsolation {
	// this code uses latches and thread sleeps instead of Mutex and delay to mimic
	// a code path which ignores coroutine cancellation
	firstStarted.countDown()
	repeat(10) {
	@Suppress("BlockingMethodInNonBlockingContext")
	Thread.sleep(100)
	output.add(it)
	}
	}
	}

	val job2 = GlobalScope.launch {
	@Suppress("BlockingMethodInNonBlockingContext")
	firstStarted.await()
	singleRunner.runInIsolation {
	repeat(10) {
	output.add(it + 10)
	}
	}
	}
	runBlocking {
	withTimeout(10.seconds) {
	job2.join()
	}
	}
	assertThat(output).isEqualTo(
	// if cancellation is ignored, make sure we wait for it to finish.
	(0 until 20).toList()
	)
	}

Conversation

veyndan commented Jun 1, 2023

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

2 participants