ThreadPoolExecutor添加线程不执行,为什么 5C

import com.google.common.util.concurrent.ThreadFactoryBuilder;

import java.util.concurrent.*;

public class MyBlockingQueue implements Runnable {

BlockingQueue<String> queue;

private int index;

public MyBlockingQueue(BlockingQueue<String> queue, int index) {
    this.queue = queue;
    this.index = index;
}

@Override
public void run() {
    try {
        queue.put(String.valueOf(this.index));
        System.out.println("{" + this.index + "} in queue!");
    } catch (Exception e) {
        e.printStackTrace();
    }
}

public static void main(String args[]) {
    BlockingQueue<String> queue = new LinkedBlockingQueue<String>(3);

    ThreadFactory factory = new ThreadFactoryBuilder().setNameFormat("aaa-%s").build();
    ExecutorService pool = new ThreadPoolExecutor(5, 200, 0L, TimeUnit.MILLISECONDS,
            new LinkedBlockingQueue<>(1024), factory, new ThreadPoolExecutor.AbortPolicy());

    for (int i = 0; i < 10; i++) {
        pool.submit(new MyBlockingQueue(queue, i));
    }

  //为什么这里的线程不执行呢?
    pool.submit(() -> {
        try {
            while (true) {
                System.out.println("=======" + queue.size());
                if (queue.isEmpty()) {
                    break;
                }
                String str = queue.take();
                System.out.println(str + " has take!");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    });

    pool.shutdown();
}

}

1

1个回答

首先想说一下,其中的问题,阻塞队列和工厂模式OK,
在创建线程池的时候并不建议使用ExecutorService 中的构造函数,而是使用Executors里面提供的四种静态方法,很多的参数配置已经写好。

其次,给线程池submit的应该是线程,而不是阻塞队列,你那里submit的是阻塞队列噢,循环体里面你可以写一个自己的类
比如(class MyThread extends Thread),再写一个print,sleep一下,就可以看到线程池的执行啦。

https://blog.csdn.net/whandwho/article/details/82931798 这个博客下方第八点

1
whandwho
大川里的小川人 回复adongsha: 是我没有说清楚哇?最后的那一条,已经说清楚了嘛,有什么问题你再问嘛。
8 个月之前 回复
whandwho
大川里的小川人 回复adongsha: 我重新完整看了一遍你的代码。我帮你理一下你的思路,首先,你实现了runnable接口新建了一个线程类,线程类内部定义了index和一个string的阻塞队列。 其次,在main函数里面,你内部定义了一个String的阻塞队列,而针对线程池的阻塞队列,类型应该是线程类。 最后,你submit的是你自己定义的线程类,OK,然后你讲阻塞队列里面的取出来,取出来的是定义为String的阻塞队列内部内容。但是你实例化的是自己定义的实现runnable接口线程类MyBlockdeQuene.
8 个月之前 回复
whandwho
大川里的小川人 回复adongsha: 但是你submit的是队列,就算你这样是参考的阿里规范,按照你的意思,我submit的是阻塞队列,OK,没有问题。接着那么阻塞队列里面存放的应该是 Thread 线程,而不是 String。 所以就算你submit了一个队列,但是你队列里面存放的也不是线程Thread。
8 个月之前 回复
whandwho
大川里的小川人 接着那么阻塞队列里面存放的应该是 Thread 线程,而不是 String。
8 个月之前 回复
whandwho
大川里的小川人 回复adongsha: 但是你submit的是队列,就算你这样是参考的阿里规范,按照你的意思,我submit的是阻塞队列,OK,没有问题。
8 个月之前 回复
adongsha
adongsha 这种方式的写法是参考阿里java规范的写法,你提倡的那种写法,阿里规范是不建议的哦
8 个月之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
spring线程池ThreadPoolExecutor配置以及FutureTask的使用
最代码,http://www.zuidaima.com/share/1724478138158080.htm 的代码及例子
通过窗口传递让主线程触发FIRE事件(子线程不能触发)
通过窗口传递让主线程触发FIRE事件(子线程不能触发)
ThreadPoolExecutor的使用和Android常见的4种线程池使用介绍
ThreadPoolExecutor的使用和Android常见的4种线程池使用介绍
ThreadPoolExecutor使用和思考
ThreadPoolExecutor使用和思考
通过代码证明HashMap是线程不安全的(只用了一个Java文件)
NULL 博文链接:https://flyfoxs.iteye.com/blog/1198030
多线程Java学习
什么是线程 为什么学习线程 多线程的使用 线程同步是什么 线程的生命周期
多线程正确调用,避免假死
正确使用多线程,需要定义委托,而在使用循环时,若不正确使用,会出现屏幕假死现象。结合自身测试,写出假死出现原因和修正方式。
shiro 不执行授权方法 doGetAuthorizationInfo()
NULL 博文链接:https://rd-030.iteye.com/blog/2359792
自定义线程消息循环
建立线程自己的消息循环,接收发给本线程的用户自定义消息,涵盖了多线程通信的知识,也可以转化为线程池
Java线程基础知识
本教程研究了线程的基础知识 — 线程是什么、线程为什么有用以及怎么开始编写使用线程的简单程序。
java线程知识书籍
本教程研究了线程的基础知识— 线程是什么、线程为什么有用以及怎么开始编写使用线程的程序。
Android开发中为什么要用到线程
1,Android开发过程中为什么要线程 2,Android中使用Thread线程会遇到哪些问题
ControllableThreadPoolExecutor
ThreadPoolExecutor线程池源码
ImportFile.rar 第二版
eclipse,java,ThreadPoolExecutor
JDK1.5中的线程池
JDK1.5中的线程池(ThreadPoolExecutor)使用简介
关于如何解决HashMap线程安全问题的介绍
HashMap为什么是线程不安全的?如何解决HashMap的线程不安全问题?
Java线程完全教程
java线程完全教程 为什么要使用线程 创建线程的几种方式 死锁问题 线程生命周期 线程同步 绝对物美价廉
simpleDateFormat是线程不安全的
NULL 博文链接:https://flynndang.iteye.com/blog/711878
练习:多线程实现后台播放背景音乐的service
练习:多线程实现后台播放背景音乐的service
spring 多线程队列执行
spring 多线程队列执行
ThreadPoolExecutor线程池
ThreadPoolExecutor线程池,有详尽介绍,本人进行过测试,可以使用
跨线程日志输出到RichTextBox类库源代码
跨线程日志输出到RichTextBox类库源代码,不调用任何第3方日志类库,纯源代码奉上!主要用在WinForm上,支持线程中直接输出日志到主窗口的richTextBox上。非常好用。并且调用方便! 此压缩包带案例示范,新手一看就能调用!!!!
Delphi写的OCX控件,带有事件,由子线程触发事件,JS补抓事件
此控件是用于一款CASHCODE纸币识别器的控制驱动。 大致的实现方法请参考代码。
autoResetEvent示例
1个线程添加任务,3个线程取任务进行计算,用autoResetEvent实现添加任务线程与去任务线程的同步。
Log4j打印日志添加线程ID
区分每个请求用户,更好的跟踪分析解决问题(用户登录之后加上userId更佳)
Windows2008计划任务不能定时执行解决思路
Windows2008计划任务不能定时执行解决思路
串口单独一个线程
是串口接收单开一个线程,和主线程并行工作,界面设计简单,自己可以改一下 新的线程用的是 moveToThread(&thread);
Java线程(基础篇)
本教程研究了线程的基础知识— 线程是什么、线程为什么有用以及怎么开始编写使用线程的简单 程序。 如何在线程之间交换数据、如何控制 线程以及线程如何互相通信。
Mybatis中执行String类型的自己拼写的sql,不执行配置文件中的sql
Mybatis中执行String类型的自己拼写的sql,不执行配置文件中的sql mybatis sql connection mybatis中使用sql,不实用配置文件中的sql实例
线程池的submit和execute的区别.md
MarkDown文档,意在说明线程池方法:submit()和execute()方法的区别
ie不执行javascript修复
ie不执行javascript修复ie不执行javascript修复ie不执行javascript修复 当IE不能正常运行时,打开该工具就可以了,自动修复
JDK1[1].5中的线程池(ThreadPoolExecutor)使用简介
JDK1[1].5中的线程池(ThreadPoolExecutor)使用简介
android SurfaceView添加线程源码
android SurfaceView添加线程源码
为何SurfaceView能够在非UI线程中刷新界面(内容为代码的demo而并非文档)
重点讲解为什么普通view不能在非UI线程刷新界面,而SurfaceView可以.内容为代码的demo而并非文档
线程池源码分析
线程池ThreadPoolExecutor的源码分析,含中文注释,深入了解线程池的构造
C#实现多线程操作控件
本项目使用VS2008平台的C#语言使用多线程操作,并在线程中实现了对主线程控件的使用。
ondraw不执行,请大神帮忙
ondraw不执行,请大神帮忙
测试Service中开启Thread
测试Service中开启线程修改Activity
DELPHI XE10 多线程与单线程动态生成VCL控件
百思不得其解,多线程与单线程操控VCL控件怎么会有这大的差别,编译了32位与64位两个版本,供测试。请高手帮忙解释一下。
spirng的ThreadPoolExecutor
NULL 博文链接:https://cywhoyi.iteye.com/blog/1939040
文章热词 机器学习教程 Objective-C培训 交互设计视频教程 颜色模型 设计制作学习
相关热词 mysql关联查询两次本表 native底部 react extjs glyph 图标 为什么学python 为什么学习产品经理