У меня код который создает два потока, и если они не успевают отработать в определенный должен прерывать их. Но что-то идет не так, потоки вместо того что-бы прерваться продолжают работать.
Вот код:
public class CounterOfSpace {
private int counterOfSpaces;
private int counterOfWords;
private String text;
private Thread thread01;
private Thread thread02;
public CounterOfSpace(String text) {
this.text = text;
}
void startAll() {
System.out.println("Start program");
calcWords();
calcSpaces();
stopThreads();
thread01.start();
thread02.start();
try {
thread01.join();
thread02.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Finish program");
}
private void calcSpaces() {
thread01 = new Thread(new Runnable() {
@Override
public void run() {
if (text.length() == 0) return;
for (char c : text.toCharArray()) {
if (c == ' ') {
counterOfSpaces++;
System.out.println("counterOfSpaces "+counterOfSpaces);
}
}
}
});
}
private void calcWords() {
thread02 = new Thread(new Runnable() {
@Override
public void run() {
if (text.length() == 0) return;
String[] words = text.split(" ");
for (String word : words) {
if (!word.equals(" ")) {
counterOfWords++;
System.out.println("counterOfWords "+counterOfWords);
}
}
}
});
}
private void stopThreads() {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(3);
Future handler1 = executor.submit(thread01);
Future handler2 = executor.submit(thread02);
Runnable r = new Runnable() {
@Override
public void run() {
handler1.cancel(true);
handler2.cancel(true);
}
};
executor.schedule(r, 3, TimeUnit.MILLISECONDS);
}
}
В самом низу, метод который в последней строчке должен останавливать потоки executor.schedule(r, 3, TimeUnit.MILLISECONDS);
. Среднее время выполнения этой программы, без прерываний, около 40 мс, так что 3 мс вполне достаточно.
Но программа и с вызывом метода stopThreads()
так же отрабатывает до конца все потоки, и 3мс совершенно ее не смущают. Помогите разобраться что не так?