Форум программистов, компьютерный форум, киберфорум
turbanoff
Войти
Регистрация
Восстановить пароль
Рейтинг: 5.00. Голосов: 1.

Поток, который можно попросить приостановить работу

Запись от turbanoff размещена 10.04.2014 в 20:05
Обновил(-а) turbanoff 11.04.2014 в 14:39

Пример потока, который можно правильно приостановить и возобновить
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
import java.io.IOException;
import java.util.concurrent.TimeUnit;
 
class StoppableTask implements Runnable {
    //Пишем и читаем isStopRequired только в блоке синхронизации, чтобы поток увидел наш запрос
    private boolean isStopRequired;
    private final Object lock = new Object();
 
    @Override
    public void run() {
        while (true) {
            synchronized (lock) {
                //Если нас попросили остановиться - будем ждать (цикл из-за spurious wakeups)
                while (isStopRequired) {
                    try {
                        lock.wait();
                    } catch (InterruptedException ignored) {
                    }
                }
            }
            System.out.println("Работаем");
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException ignored) {
            }
        }
    }
 
    public void requestStop() {
        System.out.println("Stop request");
        synchronized (lock) {
            isStopRequired = true;
        }
    }
 
    public void requestResume() {
        System.out.println("Resume request");
        synchronized (lock) {
            isStopRequired = false;
            lock.notify();
        }
    }
}
 
public class Main {
    public static void main(String[] args) throws IOException, InterruptedException {
        StoppableTask task = new StoppableTask();
        Thread thread = new Thread(task);
        thread.setDaemon(true);
        thread.start();
 
        TimeUnit.SECONDS.sleep(10); //дадим потоку поработать 10 сек
 
        task.requestStop(); //останавливаем
 
        TimeUnit.SECONDS.sleep(5); //убеждаемся что поток стоит
 
        task.requestResume(); //возобновляем
 
        TimeUnit.SECONDS.sleep(5); //убеждаемся что поток возобновил работу
    }
}
Размещено в Java
Показов 4179 Комментарии 0
Всего комментариев 0
Комментарии
 
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2022, CyberForum.ru