Почему мой форк / присоединенный тупик? - PullRequest
Новая
       16

Почему мой форк / присоединенный тупик?

2 голосов
/ 27 сентября 2011

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

def pathSizes = []
paths.each { rootPath ->
  pathSizes.addAll(
    withPool { pool ->
      runForkJoin(rootPath) { path ->
        def headSizes = [:]
        println path

        def lines = ["ls", "-al", path].execute().text.readLines()
        (0..<3).each { lines.remove(0) }
        lines.each { line ->
          def fields = line.split(/\s+/)
          if (fields[0] =~ /^d/)
            forkOffChild("$path/${fields.last()}")
          else {
            def userName = fields[2]
            def fileSize = fields[4] as long
            if (headSizes[userName] == null)
              headSizes[userName] = fileSize
            else
              headSizes[userName] += fileSize
          }
        }

        quietlyJoin()
        System.gc()

        def shallowSizes =
          headSizes.collectEntries { userName, fileSize ->
            def childResult =
              childrenResults.sum {
                 it.shallowSizes[userName] ? it.shallowSizes[userName] : 0
              } ?: 0
            return [userName, fileSize + childResult]
          }

        def deepSizes =
          childrenResults.sum { it.deepSizes ?: [] } +
          shallowSizes.collect { userName, fileSize ->
            [userName: userName, path: path, fileSize: fileSize]
          }

        return [shallowSizes: shallowSizes, deepSizes: deepSizes]
      }.deepSizes
    })
}

Почему этот фрагмент кода тупик? Нет взаимодействия между потоками, за исключением, возможно, системного вызова и других частей инфраструктуры Java. Если проблема связана с системными вызовами, то как я могу это исправить, не удаляя системные вызовы (они медленные, отсюда и необходимость распараллеливания)?

...