如何最有效地使用Groovy/GPars处理CSV文件的行？

groovysh -e "grape install org.codehaus.gpars gpars"

import static groovyx.gpars.GParsPool.withPool
import static groovyx.gpars.dataflow.Dataflow.task

import java.util.concurrent.ConcurrentHashMap

def csvFile = new File("input.csv")
def outputDir = new File("output")

def processRow = { row ->
    // 处理CSV文件的行
    return "Processed row: $row"
}

def processFile = { file ->
    def outputFile = new File(outputDir, file.name)
    outputFile.withWriter { writer ->
        file.eachLine { line ->
            def processedRow = processRow(line)
            writer.println(processedRow)
        }
    }
}

withPool {
    csvFile.eachFileMatch(~/.*\.csv/) { file ->
        task {
            processFile(file)
        }
    }
}

groovy script.groovy