@@ -508,7 +508,6 @@ internal class CoroutineScheduler(
508
508
* E.g. for [1b, 1b, 2c, 1d] means that pool has
509
509
* two blocking workers with queue size 1, one worker with CPU permit and queue size 1
510
510
* and one dormant (executing his local queue before parking) worker with queue size 1.
511
- * TODO revisit
512
511
*/
513
512
override fun toString (): String {
514
513
var parkedWorkers = 0
@@ -551,10 +550,10 @@ internal class CoroutineScheduler(
551
550
" running workers queues = $queueSizes , " +
552
551
" global CPU queue size = ${globalCpuQueue.size} , " +
553
552
" global blocking queue size = ${globalBlockingQueue.size} , " +
554
- " Control State Workers {" +
555
- " created = ${createdWorkers(state)} , " +
556
- " blocking = ${blockingTasks(state)} , " +
557
- " CPU acquired = ${corePoolSize - availableCpuPermits(state)} " +
553
+ " Control State {" +
554
+ " created workers = ${createdWorkers(state)} , " +
555
+ " blocking tasks = ${blockingTasks(state)} , " +
556
+ " CPUs acquired = ${corePoolSize - availableCpuPermits(state)} " +
558
557
" }]"
559
558
}
560
559
@@ -595,7 +594,7 @@ internal class CoroutineScheduler(
595
594
* Worker state. **Updated only by this worker thread**.
596
595
* By default, worker is in DORMANT state in the case when it was created, but all CPU tokens or tasks were taken.
597
596
*/
598
- @Volatile
597
+ @JvmField
599
598
var state = WorkerState .DORMANT
600
599
val isBlocking: Boolean get() = state == WorkerState .BLOCKING
601
600
0 commit comments