java-在动态线程号中调用ExecutorService.shutdown

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java-在动态线程号中调用ExecutorService.shutdown，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1592字，纯文字阅读大概需要3分钟。

内容图文

我所在时区的早安.

我正在使用线程池开发一个小型Http机器人,该机器人从每个页面的链接移动到链接.当我找到新链接时,我创建了一个新线程来探索该新页面.
伪代码.

pool = Executors.newFixedThreadPool(40);

pool.execute(new Exploit(tree.getRoot()));

在这种情况下,Exploit是一个内部类,该类实现Runnable接口并可以访问池,因此每次一个线程找到链接时,都将使用该池来添加新的“线程”,如下所示：

for(Link n : links){
   pool.execute(new Exploit(n));
 }

我看到了很多使用ExecutorService类的示例,但是它们都使用相同的代码,例如：

ExecutorService executor = Executors.newFixedThreadPool(NTHREDS);
for (int i = 0; i < 500; i++) {
    Runnable worker = new MyRunnable(10000000L + i);
    executor.execute(worker);
}
   // This will make the executor accept no new threads
   // and finish all existing threads in the queue
    executor.shutdown();

在上面的代码中,线程数是静态的,因此当代码调用shutdown时,所有线程已添加到池中.我无法遵循此代码,因为在我的情况下,我没有要添加的静态线程数.我停止向池中添加更多线程的条件是当我到达搜索深度级别时.所以我的问题是,如何在主线程中调用executor.shutdown？我可以在主线程中使用任何一种连接吗？

提前致谢.
最好的祝福

解决方法:

您可以看一下Phaser.您仍然可以使用固定数量的线程,但是每次找到链接时,您都可以注册另一方并根据该链接提交可运行对象.

Phaser phaser = new Phaser(1);
ExecutorService e = Executors.newFixedThreadPool(n);

public void crawl(final String url){
   visit(url);
   phaser.arriveAndAwaitAdvance();
   e.shutdown();  
}

private void visit(String url){
    phaser.register();
    e.submit(new Runnable(){
        public void run(){
            //visit link maybe another visit(url)             
            phaser.arrive();
        } 
    });
}

在这一点上,e.shutdown()在访问所有链接之前永远不会发生.

内容总结

以上是互联网集市为您收集整理的java-在动态线程号中调用ExecutorService.shutdown全部内容，希望文章能够帮你解决java-在动态线程号中调用ExecutorService.shutdown所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端