我在同一个目录下有许多文件。这些文件不依赖于其他文件。
下面是我的代码:
from("sftp://${sftp.username}:${sftp.password}@${sftp.host}:${sftp.port}/myDirectory?" +
"readLock=changed&readLockMinAge=10s&autoCreate=true" +
"&move=finish/$simple{date:now:yyyyMMdd}/$simple{file:onlyname}" +
"&moveFailed=failed/$simple{date:now:yyyyMMdd}/$simple{file:onlyname}")
.threads(5,20)
.keepAliveTime(20)
.process(parseTypeProcessor)
.process(uploadToOSSProcessor)
.process(saveImgProcessor)
.end();
但它并不是使用5个线程从目录myDirectory下载5个文件并同时处理5个文件,而是使用单个线程处理文件。
使用单线程处理文件太慢了。我想使用多线程处理这些文件。有什么方法可以做到这一点吗?任何帮助都将不胜感激
1条答案
按热度按时间sg24os4d1#
有一个关于并发下载的JIRA票。想要这样做的用户可以使用JIRA投票为它添加更多的投票:
https://issues.apache.org/jira/browse/CAMEL-6058
查看部分链接