Java поток простой очереди

Question

Я пытаюсь создать простую очередь с Java-потоком, которая позволила бы циклу, скажем циклу for с 10 итерациями, выполнять итерацию по n (< 10) потоков одновременно и ждать, пока эти потоки не будут завершены, прежде чем продолжить итерацию.

Вот лучший способ проиллюстрировать мою проблему:

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
}

По сути, я хочу сделать копию этого: поток и очередь

Как мне достичь этого самым безболезненным способом?

Answer 1

Я бы использовал Java 5 Executors вместо того, чтобы катиться самостоятельно. Что-то вроде следующего:

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
service.shutdown();
// now wait for the jobs to finish
service.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);

Answer 2

Используйте Исполнителей, как рекомендовано другими. Однако, если вы хотите получить удовольствие от этого, попробуйте что-то вроде этого. (Будьте осторожны. Я написал это в Блокноте, и есть некоторые исключения, которые вам нужно будет отследить, даже если я все правильно понял. Блокнот плохо распознает ошибки кодирования.) Это скорее концепция, чем реальное решение чего-либо, но идея может быть в целом полезным.

private ConcurrentLinkedQueue<MyThread>  tQueue =
             new ConcurrentLinkedQueue<MyThread>();

class MyThread  extends Thread  {
    public Runnable  doSomething;

    public void run()  {
        // Do the real work.
        doSomething();
        // Clean up and make MyThread available again.
        tQueue.add( mythread );
        // Might be able to avoid this synch with clever code.
        // (Don't synch if you know no one's waiting.)
        // (But do that later.  Much later.)
        synchronized (tQueue)  {
            // Tell them the queue is no longer empty.
            tQueue.notifyAll();
        }
    }
}

В другом месте:

// Put ten MyThreads in tQueue.
for (int i = 0; i < 10; i++)  tQueue.add( new MyThread() );

// Main Loop.  Runs ten threads endlessly.
for (;;)  {
    MyThread  t = tQueue.poll();
    if (t == null)  {
        // Queue empty.  Sleep till someone tells us it's not.
        do  {
            // There's a try-catch combo missing here.
            synchonized( tQueue )  { tQueue.wait() };
            t = tQueue.poll();
        }  while (t == null)  break;  // Watch for fake alert!
    }
    t.doSomething = do_some_work;
    t.start();
}

Также обратите внимание на умное использование ConcurrentLinkedQueue. Вы можете использовать что-то еще, например, ArrayList или LinkedList, но вам нужно их синхронизировать.

Answer 3

См. java.util.concurrent и особенно Executors и ExecutorService

Answer 4

Клеть Logger.class:

public class Logger extends Thread {
    List<String> queue = new ArrayList<String>();
    private final int MAX_QUEUE_SIZE = 20;
    private final int MAX_THREAD_COUNT = 10;

    @Override
    public void start() {
        super.start();
        Runnable task = new Runnable() {
            @Override
            public void run() {
                while (true) {
                    String message = pullMessage();
                    Log.d(Thread.currentThread().getName(), message);
                    // Do another processing
                }
            }
        };
        // Create a Group of Threads for processing
        for (int i = 0; i < MAX_THREAD_COUNT; i++) {
            new Thread(task).start();
        }
    }

    // Pulls a message from the queue
    // Only returns when a new message is retrieves
    // from the queue.
    private synchronized String pullMessage() {
        while (queue.isEmpty()) {
            try {
                wait();
            } catch (InterruptedException e) {
            }
        }
        return queue.remove(0);
    }

    // Push a new message to the tail of the queue if
    // the queue has available positions
    public synchronized void pushMessage(String logMsg) {
        if (queue.size() < MAX_QUEUE_SIZE) {
            queue.add(logMsg);
            notifyAll();
        }

    }
}

Затем введите ниже код в вашем основном классе:

Logger logger =new Logger();
logger.start();
for ( int i=0; i< 10 ; i++) {
    logger.pushMessage(" DATE : "+"Log Message #"+i);
}