我试图使用java.util.concurrent.Executor并行执行独立的任务。
我有以下工作代码
public class MiniTest {
private static String[] input;
static {
input = new String[] {
"task1",
"task2",
"task3",
"task4"
};
}
public static void main(String[] args) throws InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(2);
boolean atleastOnePoolStarted = false;
for (int i = 0; i < input.length; i++) {
Runnable worker = new WorkerThread(input[i] + i);
executor.execute(worker);
}
executor.shutdown();
executor.awaitTermination(15,TimeUnit.MINUTES);
System.out.println("Finished all threads");
}
}这是很好的工作,我看到并行执行。
但是问题是,当我用我的另一个类替换WorkerThread时,这个类是Runnable,并通过连接到数据库进行存储过程调用。在这种情况下,线程正在启动,但是对存储过程的实际调用似乎是以一种过程的方式进行的,即第二个java-proc调用在第一个调用完成之前不会被执行。
数据库部分工作正常,因为这是独立验证和测试的。我只需要同时打2-3个电话。我正在使用Sybase作为数据库。
以前有人遇到过这个问题吗?请告诉我可能出了什么问题。
发布于 2013-09-18 14:45:25
关于什么可能是错误的几个想法:
https://stackoverflow.com/questions/18875046
复制相似问题