我们如何以循环方式使用多线程？

Question

我想以多线程方式阅读10个邮件帐户的未读邮件。

但是如果线程池大小为5，那么将使用线程池中的5个线程。每个线程将读取一个邮件帐户。因此，一旦Thread_1读取了第一个邮箱，它应该会读取mailbox_6。那么线程2将读取mailbox_7。

当所有邮件帐户都被读取一次后，循环将从第一个邮件帐户开始。

我们如何在java中做到这一点？

Answer 1

简单地创建任务的并发（或同步，在这种情况下并不重要）集合（可能是队列）怎么样？每个任务都将从电子邮件帐户中加载所需的数据。然后让每个线程从集合中获取一个任务，直到它为空。

每个线程都将有一个对该集合的引用，并将对其进行循环。当集合不为空时，从它中获取一个任务并对其进行处理。

Answer 2

跟踪已读取的电子邮件帐户。例如定义这样的东西，

//total number of email accounts that need to be read.
private int noOfEmails=10;

//the thread pool that is used to read the emails
private ExecutorService threadPool = Executors.newFixedThreadPool(5);

//the tracker array that keeps track of the emails that 
//are already read. This array is cleared only after all 10
//emails are read. 
private ArrayList<String> emailTracker=new ArrayList<String>(noOfEmails);

//any changes to emailTracker should be synchronized as 
//this is a common data shared between all 5 threads.
private Object syncObject=new Object();

在Runnable实现中，检查emailTracker是否包含您的电子邮件帐户标识符，如果这样意味着它已被读取，则返回并等待emailTracker被清除。当所有10个电子邮件帐户都被读取时，它将被清除。

        if(emailTracker.contains(email.identifier))
        {
            return;
        }

        //read email.
        email.read();
        //simple synchronization.
        synchronized (syncObject)
        {
            //read email
            emailTracker.add(email.identifier);
            //if all emails are read, clear the tracker
            //This will allow reading of all the emails 
            //once again.
            if(emailTracker.size()==noOfEmails)
            {
                emailTracker.clear();
            }

        }

Answer 3

这应该很容易。创建一个包含 5 个线程的固定线程池，然后将 10 个作业提交到该池 -- 每个用户电子邮件帐户 1 个：

// create a thread pool with 5 workers
ExecutorService threadPool = Executors.newFixedThreadPool(5);
// submit all 10 user email accounts to the pool to be processed in turn
for (UserEmail userEmail : userEmailsToProcess) {
    threadPool.submit(new EmailProcessor(userEmail));
}
// once we have submitted all jobs to the thread pool, it should be shutdown
threadPool.shutdown();
...
// here's our runnable class which does the actual work
public class EmailProcessor implements Runnable {
    private UserEmail userEmail;
    public MyJobProcessor(UserEmail userEmail) {
        this.userEmail = userEmail;
    }
    public void run() {
        // read the user email
        ...
    }
}

UserEmail类可以保存要“读取”的电子邮件的文件名，或者可能是帐户名或其他内容。这将由您决定如何表示邮件帐户和要阅读的邮件。

[[ 来自评论：]]

我有10个邮箱，像..邮箱1...mailbox10，现在我从线程池中有5个线程，所以线程1将获取任何邮箱，所以让我们假设它将选择邮箱1，然后线程2将选择邮箱2，线程3将选择邮箱3，线程4将选择邮箱4，thread5将选择邮箱5，现在当线程1（已定义的特定时间段）将释放时，那么它应该选择邮箱6 - mailbox10， 任何尚未读取它的人都不应该从mailbox1 - mailbox5中选择任何邮箱，直到所有尚未读取的邮箱。

哦，我明白了。一种解决方案是让一个调度线程时不时地Hibernate和唤醒，以查看邮箱中是否有邮件。如果是这样，那么它会将一个作业提交给线程池，以便读取该邮箱。一旦邮箱被读取，线程返回并请求处理下一个邮箱。分派线程将继续向线程池添加邮箱，直到被告知停止。

如果电子邮件处理器中有大量上下文，那么您可以拥有线程池，但它们可以从阻塞队列中消耗