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
whandwho 回复adongsha: 是我没有说清楚哇?最后的那一条,已经说清楚了嘛,有什么问题你再问嘛。
2 个月之前 回复
whandwho
whandwho 回复adongsha: 我重新完整看了一遍你的代码。我帮你理一下你的思路,首先,你实现了runnable接口新建了一个线程类,线程类内部定义了index和一个string的阻塞队列。 其次,在main函数里面,你内部定义了一个String的阻塞队列,而针对线程池的阻塞队列,类型应该是线程类。 最后,你submit的是你自己定义的线程类,OK,然后你讲阻塞队列里面的取出来,取出来的是定义为String的阻塞队列内部内容。但是你实例化的是自己定义的实现runnable接口线程类MyBlockdeQuene.
2 个月之前 回复
whandwho
whandwho 回复adongsha: 但是你submit的是队列,就算你这样是参考的阿里规范,按照你的意思,我submit的是阻塞队列,OK,没有问题。接着那么阻塞队列里面存放的应该是 Thread 线程,而不是 String。 所以就算你submit了一个队列,但是你队列里面存放的也不是线程Thread。
2 个月之前 回复
whandwho
whandwho 接着那么阻塞队列里面存放的应该是 Thread 线程,而不是 String。
2 个月之前 回复
whandwho
whandwho 回复adongsha: 但是你submit的是队列,就算你这样是参考的阿里规范,按照你的意思,我submit的是阻塞队列,OK,没有问题。
2 个月之前 回复
adongsha
adongsha 这种方式的写法是参考阿里java规范的写法,你提倡的那种写法,阿里规范是不建议的哦
2 个月之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的。是时候展现真正的技术了!