使用 Java 线程创建一个简单的队列

沃梦达教程 Java问题

2022-01-01

Create a simple queue with Java threads(使用 Java 线程创建一个简单的队列)

本文介绍了使用 Java 线程创建一个简单的队列的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

我正在尝试使用 Java Thread 创建一个简单的队列，该队列将允许一个循环，例如一个具有 10 次迭代的 for 循环，一次迭代 n (< 10) 个线程并等待这些线程完成后再继续迭代.

I'm trying to create a simple queue with Java Thread that would allow a loop, say a for loop with 10 iterations, to iterate n (< 10) threads at a time and wait until those threads are finished before continuing to iterate.

这里有一个更好的方式来说明我的问题:

Here's a better way to illustrate my problem:

for (int i = 1; i <= 10; i++) {
    new Thread ( do_some_work() );

    if ( no_available_threads ) {
        wait_until_available_threads();
    }
}

do_some_work() {
    // do something that takes a long time
}

基本上我想要做的是这个的副本:线程和队列

Basically what I want to do is a copy of this: Thread and Queue

我怎样才能以最轻松的方式实现这一目标?

How can I achieve this the most painless way?

推荐答案

我会使用 Java 5 Executors 而不是自己滚动.类似于以下内容:

I would use the Java 5 Executors instead of rolling your own. Something like the following:

ExecutorService service = Executors.newFixedThreadPool(10);
// now submit our jobs
service.submit(new Runnable() {
    public void run() {
        do_some_work();
    }
});
// you can submit any number of jobs and the 10 threads will work on them
// in order
...
// when no more to submit, call shutdown, submitted jobs will continue to run
service.shutdown();
// now wait for the jobs to finish
service.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);

这篇关于使用 Java 线程创建一个简单的队列的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！

线程