我有这段代码:
class GitDownloader extends DefaultActor {
private String dir
@Override
protected void act() {
loop {
react {
repos -> if (repos instanceof String[])
println "Total Repos: ${repos.size()}"
repos.each {
repo ->
"git clone ssh://git@bar-src.foo.com/${repo} ${dir}/${repo.split("/").last()}".execute()
}
}
}
}
}
我是这样开始的:
def gitDownloader = new GitDownloader(dir: sourceCodeFolder)
gitDownloader.start()
gitDownloader << repositories
问题在于任务以随机顺序执行。
它应该与repos.size()一样多次运行
git clone
命令,但实际上不应这样做。每次运行随机次数。该
each
循环应作为单个任务在后台执行,似乎git clone
命令是并行执行的。 最佳答案
如果您要发送列表,它将被接收到一个列表...
如下代码:
import groovyx.gpars.actor.*
class GitDownloader extends DefaultActor {
private String dir
@Override
protected void act() {
loop {
react { repos ->
println "Got an ${repos.getClass()} of repos"
repos.each {
repo ->
println "doing $repo for dir $dir"
}
}
}
}
}
def g = new GitDownloader(dir:'woo')
g.start()
g << ['a', 'b']
打印品:
Got an class java.util.ArrayList of repos
doing a for dir woo
doing b for dir woo
这似乎按预期工作...
或将其更改为一次执行一次(添加了睡眠以模拟正在完成的某些工作)
import groovyx.gpars.actor.*
class GitDownloader extends DefaultActor {
private String dir
@Override
protected void act() {
loop {
react { repo ->
println "Got an ${repo.getClass()} of repos"
println "doing $repo for dir $dir"
Thread.sleep(1000)
}
}
}
}
def g = new GitDownloader(dir:'woo')
g.start()
g << 'a' << 'b'
g
也可以使用并打印:
Got an class java.lang.String of repos
doing a for dir woo
Got an class java.lang.String of repos
doing b for dir woo
从您的代码中,我看不到问题(除了
String[]
之外)