I am working on a multithreading program that sends emails to my clients. However, I am facing some issues with the threads in my code - they only close the window of Firefox and do not continue the desired actions. I am looking to create an algorithm where if a thread encounters issues and closes the Firefox window (using Selenium), it should then retrieve new parameters from my database and restart the thread with these new parameters. Additionally, I would like to have 5-10 threads running continuously at all times.
Main method:
static String path = "C:\\Users\\Admin\\Desktop\\clients.txt";
static String path_ok = "C:\\Users\\Admin\\Desktop\\clients2.txt";
static Integer numberMail = 1;
static List<User> users = new ArrayList<User>();
YandexConfig config1 = new YandexConfig("login1", "password1", "cookies", port1);
YandexConfig config2 = new YandexConfig("login2", "password2", "cookies", port2);
ExecutorService executor = Executors.newFixedThreadPool(50);
CompletableFuture.runAsync(new DoThread("thread 1", path, path_ok, numberMail, users, config1), executor);
CompletableFuture.runAsync(new DoThread("thread 2", path, path_ok, numberMail, users, config2), executor);
doThread:
class DoThread implements Runnable {
private String threadName;
private Integer numberMail;
private String themeMessage = "Your order";
private String messageDefault = "blabla";
private final List<User> users;
private final String fileWait;
private final String fileOk;
private final YandexConfig config;
DoThread(String threadName, String fileWait, String fileOk, Integer numberMail, List<User> users, YandexConfig config) {
this.threadName = threadName;
this.fileWait = fileWait;
this.fileOk = fileOk;
this.numberMail = numberMail;
this.users = users;
this.config = config;
}
public void run() {
System.out.println("Thread #" + threadName + " started");
while (true) {
try {
auth(threadName, config.login, config.password);
break;
} catch (InterruptedException e) {
System.out.println("Something goes wrong");
e.printStackTrace();
}
}
//more code here
}
}
Question: How can I effectively restart a thread with new parameters as per the requirements outlined above?