FileTree文件的异步操作？

Question

有没有一种方法可以轻松地在 gradle 任务中以智能方式处理 FileTree 文件？我基本上需要等待所有文件的执行，就像使用 GPars 所做的那样，但是如何使用 FileTree 执行此 gradle 操作？

task compressJs(dependsOn: [copyJsToBuild]) << {
    println 'Minifying JS'

    fileTree {
        from 'build/js'
        include '**/*.js'
    }.visit { element ->
        if (element.file.isFile()) {
            println "Minifying ${element.relativePath}"
            ant.java(jar: "lib/yuicompressor-2.4.6.jar", fork: true) {
                arg(value: "build/js/${element.relativePath}")
                arg(value: "-o")
                arg(value: "build/js/${element.relativePath}")
            }
        }
    }
}

如果我能做类似 .visit{}.async(wait:true) 的事情那就太好了，但我的谷歌搜索什么也没找到。有没有办法可以轻松地使其成为多线程？一个元素的处理不会影响任何其他元素的处理。

Answer 1

在考虑使用多线程之前，我会尝试以下操作：

• 在同一个 JVM 中运行所有内容。为每个输入文件创建一个新的 JVM 效率非常低。
• 使 compressJs 任务增量，以便仅在某些输入文件自上次运行以来发生更改时才执行。
• 直接运行压缩器而不是通过 Ant 运行（节省为每个输入文件创建新的类加载器；不确定这是否重要）。

如果这仍然让您对性能不满意，并且您无法使用性能更高的压缩器，那么您仍然可以尝试使用多线程。 Gradle 还无法在这方面为您提供帮助，但 GPars 或 Java Fork/Join 框架等库可以。

Answer 2

GPars 解决方案。请注意，可以修改 compress() 函数以正确接受源目录/目标目录/等，但由于我的所有名称都是一致的，所以我现在只使用一个参数。我能够将构建时间从 7.3s 缩短到 5.4s，只缩小了 3 个文件。我见过构建时间急剧失控，所以我总是对这种行为的性能保持警惕。

import groovyx.gpars.GParsPool

buildscript {
    repositories {
        mavenCentral()
    }

    dependencies {
        classpath 'org.codehaus.gpars:gpars:0.12'
    }
}

def compress(String type) {
    def elementsToMinify = []
    fileTree {
        from type
        include "**/*.$type"
    }.visit { element ->
        if (element.file.isFile()) {
            elementsToMinify << element
        }
    }

    GParsPool.withPool(8) {
        elementsToMinify.eachParallel { element ->
            println "Minifying ${element.relativePath}"
            def outputFileLocation = "build/$type/${element.relativePath}"
            new File(outputFileLocation).parentFile.mkdirs()
            ant.java(jar: "lib/yuicompressor-2.4.6.jar", fork: true) {
                arg(value: "$type/${element.relativePath}")
                arg(value: "-o")
                arg(value: outputFileLocation)
            }
        }
    }
}

task compressJs {
    inputs.dir new File('js')
    outputs.dir new File('build/js')

    doLast {
        compress('js')
    }
}

task compressCss {
    inputs.dir new File('css')
    outputs.dir new File('build/css')

    doLast {
       compress('css')
    }
}