Котлин - сопрограммы ведут себя не так, как ожидалось - PullRequest
Новая
       15

Котлин - сопрограммы ведут себя не так, как ожидалось

0 голосов
/ 11 октября 2019

Этот вопрос связан с одним из моих предыдущих вопросов: Kotlin - сопрограммы с циклами .

Итак, это моя текущая реализация: 

fun propagate() = runBlocking {
    logger.info("Propagating objectives...")
    val variablesWithSetObjectives: List<ObjectivePropagationMapping> =
        variables.filter { it.variable.objective != Objective.NONE }
    variablesWithSetObjectives.forEach { variableWithSetObjective ->
        logger.debug("Propagating objective ${variableWithSetObjective.variable.objective} from variable ${variableWithSetObjective.variable.name}")
        val job: Job = launch {
            propagate(variableWithSetObjective, variableWithSetObjective.variable.objective, this, variableWithSetObjective)
        }
        job.join()
        traversedVariableNames.clear()
    }
    logger.info("Done")
}

private tailrec fun propagate(currentVariable: ObjectivePropagationMapping, objectiveToPropagate: Objective, coroutineScope: CoroutineScope, startFromVariable: ObjectivePropagationMapping? = null) {
    if (traversedVariableNames.contains(currentVariable.variable.name)) {
        logger.debug("Detected loopback condition, stopping propagation to prevent loop")
        return
    }
    traversedVariableNames.add(currentVariable.variable.name)
    val objectiveToPropagateNext: Objective =
        if (startFromVariable != currentVariable) {
            logger.debug("Propagating objective $objectiveToPropagate to variable ${currentVariable.variable.name}")
            computeNewObjectiveForVariable(currentVariable, objectiveToPropagate)
        }
        else startFromVariable.variable.objective
    logger.debug("Choosing variable to propagate to next")
    val variablesToPropagateToNext: List<ObjectivePropagationMapping> =
        causalLinks
            .filter { it.toVariable.name == currentVariable.variable.name }
            .map { causalLink -> variables.first { it.variable.name == causalLink.fromVariable.name } }
    if (variablesToPropagateToNext.isEmpty()) {
        logger.debug("Detected end of path, stopping propagation...")
        return
    }
    val variableToPropagateToNext: ObjectivePropagationMapping = variablesToPropagateToNext.random()
    logger.debug("Chose variable ${variableToPropagateToNext.variable.name} to propagate to next")
    if (variablesToPropagateToNext.size > 1) {
        logger.debug("Detected split condition")
        variablesToPropagateToNext.filter { it != variableToPropagateToNext }.forEach {
            logger.debug("Launching child thread for split variable ${it.variable.name}")
            coroutineScope.launch {
                propagate(it, objectiveToPropagateNext, this)
            }
        }
    }
    propagate(variableToPropagateToNext, objectiveToPropagateNext, coroutineScope)
}

IВ настоящее время выполняется алгоритм в следующей топологии переменных (обратите внимание, что алгоритм следует за стрелками, идущими к переменной, но не за стрелками, выходящими из переменной): Variable topology

В настоящее время я являюсьполучая следующий результат отладочной печати: https://pastebin.com/ya2tmc6s.

Как видите, даже несмотря на то, что я запускаю сопрограммы, они не начинают выполняться до тех пор, пока основная рекурсивная функция распространения не завершит исследование полного пути.

Я бы хотел, чтобы запущенные сопрограммы сразу же начали выполняться ...

1 Ответ

1 голос
/ 11 октября 2019

Если не указано иное, все сопрограммы, которые вы запускаете в runBlocking, будут выполняться в одном потоке.

Если вы хотите включить многопоточность, вы можете просто изменить это значение на runBlocking(Dispatchers.Default). Я просто собираюсь предположить, что весь этот код является поточно-ориентированным.

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

...