我已经开始研究一个项目,在该项目中我将传递我需要使用的线程数,然后我将尝试测量SELECT sql
执行所需的时间,因此我在这条线之前有一个计数器preparedStatement.executeQuery();
和一个计数器测量这条线之后的时间。
以下是我的代码片段-
public class TestPool {
public static void main(String[] args) {
final int no_of_threads = 10;
// create thread pool with given size
ExecutorService service = Executors.newFixedThreadPool(no_of_threads);
// queue some tasks
for(int i = 0; i < 3 * no_of_threads; i++) {
service.submit(new ThreadTask());
}
// wait for termination
service.shutdown();
service.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);
// Now print the select histogram here
System.out.println(ThreadTask.selectHistogram);
}
}
下面是我实现 Runnable 接口的 ThreadTask 类-
class ThreadTask implements Runnable {
private PreparedStatement preparedStatement = null;
private ResultSet rs = null;
public static ConcurrentHashMap<Long, AtomicLong> selectHistogram = new ConcurrentHashMap<Long, AtomicLong>();
public ThreadTask() {
}
@Override
public void run() {
...........
long start = System.nanoTime();
rs = preparedStatement.executeQuery();
long end = System.nanoTime() - start;
final AtomicLong before = selectHistogram.putIfAbsent(end / 1000000L, new AtomicLong(1L));
if (before != null) {
before.incrementAndGet();
}
..............
}
}
问题陈述:-
今天我开了一个设计会议,会议上大多数人说不要在运行程序后立即开始测量时间。有一些热身时间,然后开始测量。所以我认为在那之后这样做是有道理的。现在我在想我应该如何在我的代码中加入这个变化。我将在什么基础上这样做?任何人都可以提出一些建议吗?