现在这个设置就像运行OpenSUSE 11.3的Linux机器上的魅力一样,但是一位同事在运行Win7的非常类似的机器上测试它,在队列轮询(见下面的代码)中得到了超时的定制通知,其实很多.我一直在尝试监控她的机器上的处理器使用情况,而且似乎该软件不会超过15％的cpu,而在我的机器上,处理器使用率正好按照我的意图.
我的问题是,这能否成为排队的“饥饿”的标志？可能这样,生产者线程没有足够的cpu时间？如果是这样,我如何去给予一个特定的线程池更高的优先级？
更新：
我一直在试图找出问题,没有快乐,但是我得到了一些新的见解.
>使用JVisualVM分析代码的执行情况,显示出非常特殊的行为.这些方法以短时间的cpu时间来进行调用,几秒钟之间没有进展.这对我来说意味着操作系统在某种程度上正在制动过程中.
>禁用防病毒和备份守护程序对此事没有任何重大影响
>通过任务管理器(建议here)更改java.exe(唯一的实例)的优先级也不会改变任何东西. (也就是说,我不能给予Java的“实时”优先级,并且必须满足于“高”prio)
>分析网络使用情况显示出良好的数据流入和流出,所以我猜测这不是瓶颈(虽然这是进程执行时间的很大一部分,但是我已经知道和几乎相同的百分比正如我在Linux机器上所得到的).
有关Win7 OS如何将cpu时间限制在我的项目的任何想法？如果不是操作系统,可能是什么限制因素？我想再次强调,该机器不会同时运行任何其他计算密集型,除了我的软件之外,cpus几乎没有任何负载.这让我疯狂了
编辑：相关代码
public ConcurrencyService(Dataset d,QueryService qserv,Set<MyObject> s){
timeout = 3;
this.qs = qserv;
this.bq = qs.getQueue();
this.ds = d;
this.analyzedObjects = s;
this.drc = DebugRoutineContainer.getInstance();
this.started = false;
int nbrOfProcs = Runtime.getRuntime().availableProcessors();
poolSize = nbrOfProcs;
pool = (ThreadPoolExecutor) Executors.newFixedThreadPool(poolSize);
drc.setscoreLogStream(new PrintStream(qs.getscoreLogFile()));
}
public void serve() throws InterruptedException {
try {
this.ds.initDataset();
this.started = true;
pool.execute(new QueryingAction(qs));
for(;;){
MyObject p = bq.poll(timeout,TimeUnit.MINUTES);
if(p != null){
if (p.getId().equals("0"))
break;
pool.submit(new AnalysisAction(ds,p,analyzedObjects,qs.getKnownAssocs()));
}else
drc.log("Timed out while waiting for an object...");
}
} catch (Exception ex) {
ex.printStackTrace();
String exit_msg = "Unexpected error in core analysis,terminating execution!";
}finally{
drc.log("--DEBUG: Termination criteria found,shutdown initiated..");
drc.getMemoryInfo(true); // dump meminfo to log
pool.shutdown();
int mins = 2;
int nCores = poolSize;
long totalTasks = pool.getTaskCount(),compTasks = pool.getCompletedTaskCount(),tasksRemaining = totalTasks - compTasks,timeout = mins * tasksRemaining / nCores;
drc.log("--DEBUG: Shutdown commenced,thread pool will terminate once all objects are processed," +
"or will timeout in : " + timeout + " minutes... \n" + compTasks + " of " + (totalTasks -1) +
" objects have been analyzed so far," + "mean process time is: " +
drc.getMeanProcTimeAsString() + " milliseconds.");
pool.awaitTermination(timeout,TimeUnit.MINUTES);
}
}
QueryingAction类是一个简单的Runnable,它调用指定的QueryService对象中的数据采集方法,然后填充BlockingQueue. AnalysisAction类对MyObject的单个实例执行所有的数字处理.
