programı aynı anda farklı konulara göre posta göndermek için paralel işleme ile

Question

Ben java mail api kullanarak posta gönderen aşağıdaki program var, şimdi bu şimdi geliştirdiğim basit bir program şu anda geliştirmek istiyorum 5 farklı iş parçacığı bağımsız olarak istediğim executorframework kullanarak paralel yürütme bu programımı tetiklemelidir ancak aynı anda 5 farklı iş parçacığının aynı anda tetiklemesi gerekir

beş farklı iş parçacığı olduğunu söyleyelim t1, t2, t3, t4 ve t5 sonra hepsi bağımsız olarak(), şimdi rite çağırıyor ama aynı zamanda

java kodu benim

public class SSendEmail { 

    public static void main(String [] args) throws Exception, IOException, Exception{ 

     String smtpHost = "xxx"; 
     String mailSmtpPort = "000"; 
     String mailTo[] = {"sart@wer.com" }; 
     String mailCc[] = {"sart@wer.com" }; 






     xxsendmail(mailTo, mailCc, "sendername", 
       "testsubject.", "testsubject..", smtpHost , mailSmtpPort); 


    } 

Answer 1

Bir ScheduledExecutorService kullanır ve bunu böyle adlandırırsınız.

ScheduledExecutorService exec = Executors.newScheduledThreadPool(amount); 
for (int i = 0; i < amount; i++) { 
    exec.schedule(yourMailSendingRunnable, delay, TimeUnit.MILLISECONDS); 
} 

İhtiyaçlarınıza hesaba amount, yourMailSendingRunnable ve delay değiştirmelisiniz.

Answer 2

tek şartı 5 ipler eşzamanlı çalışması gerektiğidir sürece, böyle bir şey ile yapılır: daha fazla kontrol gerektiğinde

public class SSendEmail implements Runnable { 

    public static void main(String [] args) throws Exception, IOException, Exception{ 

     for(int i=0;i<5;i++) { 
      new Thread(new SSendMail()).start(); 
     } 
    } 

    public void run() { 

    String smtpHost = "xxx"; 
    String mailSmtpPort = "000"; 
    String mailTo[] = {"sart@wer.com" }; 
    String mailCc[] = {"sart@wer.com" }; 

    xxsendmail(mailTo, mailCc, "sendername", 
      "testsubject.", "testsubject..", smtpHost , mailSmtpPort); 
    } 
} 

Bir ExecutorService kullanacaktır. Örneğin. ThreadPooleExecutor, yeni iş parçacığına devam ettiğinizde eşzamanlı çalışan iş parçacığı sayısını sınırlamak için, ancak aynı anda 10 iş parçacığının çalıştığını sınırlamak istediğinizde.