Синхронизация потоков

@BlindFox · Регистрация: 26.04.2016

Студворк — интернет-сервис помощи студентам

Добрый день. Нужно решить уравнение методом хорд и методом касательных. Решаться должно одновременно в двух разных потоках. Поток, который первым нашел решение с требуемой точностью, выводит результат и сове имя. При этом второй поток должен сразу прерваться. Я пытался сделать, передав в потоки ссылки друг на друга, чтобы поток, который нашел решение, мог прервать второй.

Проблема в том, что иногда результат и им не выводятся после завершения программы, иногда выводятся оба результата и имени, а иногда выдается ошибка.

Main.java

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
public class Main
{
    public static void main(String[] args)
    {
        double a = 2d, b = 5d, m = 10d;
 
        ChordMethod one = new ChordMethod(a, b, m);
        TangentMethod two = new TangentMethod(a, b, m);
 
        Thread t1 = new Thread(one);
        Thread t2 = new Thread(two);
 
        one.setThread(t2);
        two.setThread(t1);
 
        one.setName(t1.getName());
        two.setName(t2.getName());
 
 
        t1.start();
        t2.start();
 
    }
}

ChordMethod.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
class ChordMethod extends Method
{
    ChordMethod(double a, double b, double m)
    {
        super(a, b, m);
    }
 
    @Override
    double nextIteration() {
 
        double res = 0;
        res = a - Functor.Func(a) * (b - a) / (Functor.Func(b) - Functor.Func(a));
        if(Functor.Func(res) < 0)
            a = res;
        else
            b = res;
 
        return res;
    }
 
}

TangentMethod.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
class TangentMethod extends Method
{
    TangentMethod(double a, double b, double m)
    {
        super(a, b, m);
    }
 
    @Override
    double nextIteration()
    {
 
        double res = (a + b) / 2;
 
        res = res - Functor.Func(res) / Functor.FuncDerivative(res);
 
        if(Functor.Func(res)*Functor.Func(b)>0)
            a = res;
        else
            b = res;
 
        return res;
    }
}

Method.java

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
class Method implements Runnable
{
    double a, b, m;
    private Thread t;
    private String name;
 
    Method(double a, double b, double m)
    {
        this.a = a;
        this.b = b;
        this.m = m;
    }
 
    double nextIteration() {
        return 0;
    }
 
    @Override
    public void run()
    {
        double res = 0;
        if(Checker.isSolution(a, b))
        {
            do {
                res = nextIteration();
 
            } while (!Checker.willStop(res, m));
            if (t.isAlive())
                t.stop();
            safePrintln("" + res);
            safePrintln(name);
        }
        else {
            if (t.isAlive())
                t.stop();
            UserInterface.showResult("There in no solution", name);
        }
 
 
 
    }
 
    public void safePrintln(String s) {
        synchronized (System.out) {
            System.out.println(s);//заменить на UserInterface
        }
    }
    void setThread(Thread t)
    {
        this.t = t;
    }
 
    void setName(String name)
    {
        this.name = name;
    }  
}

Functor.java

Java
1
2
3
4
5
class Functor
{
    static double Func(double x) { return x * x - 2 * x - 5; }
    static double FuncDerivative(double x) { return 2 * x - 2; }
}

Checker.java

Java
1
2
3
4
5
6
7
8
9
10
11
12
class Checker
{
    static boolean willStop(double x, double m)
    {
        return Math.abs(Functor.Func(x) / m) <= 0.001;
    }
 
    static boolean isSolution(double a, double b)
    {
        return Functor.Func(a) * Functor.Func(b) < 0;
    }
}

UserInterface.java

Java
1
2
3
4
5
6
7
8
9
import javax.swing.*;
 
public class UserInterface
{
    public static void showResult(String res, String name)
    {
        JOptionPane.showMessageDialog(null, "Result: " + res + "\nThread name: " + name);
    }
}

Error

Java
1
2
3
4
5
6
7
8
9
10
Exception in thread "Thread-1" java.lang.NoClassDefFoundError: Could not initialize class sun.misc.FDBigInteger
    at sun.misc.FloatingDecimal$BinaryToASCIIBuffer.dtoa(FloatingDecimal.java:448)
    at sun.misc.FloatingDecimal$BinaryToASCIIBuffer.access$100(FloatingDecimal.java:259)
    at sun.misc.FloatingDecimal.getBinaryToASCIIConverter(FloatingDecimal.java:1785)
    at sun.misc.FloatingDecimal.getBinaryToASCIIConverter(FloatingDecimal.java:1738)
    at sun.misc.FloatingDecimal.appendTo(FloatingDecimal.java:89)
    at java.lang.AbstractStringBuilder.append(AbstractStringBuilder.java:736)
    at java.lang.StringBuilder.append(StringBuilder.java:226)
    at Method.run(Method.java:30)
    at java.lang.Thread.run(Thread.java:748)

@ArtemFM · 03.03.2019, 20:11

пример тебе брошу (не используй метод stop!)

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
public class ParametersOffer {
    /**
     * Offer for work.
     */
    private String offer;
 
    /**
     * The constructor for class ParametersOffer.
     *
     * @param offer - offer for work;
     */
    public ParametersOffer(String offer) {
        this.offer = offer;
    }
 
    /**
     * The method start threads work to offer.
     *
     * @param time - max time in ms for work threads;
     */
    public void start(long time) {
        System.out.println("Start program");
        long ms = System.currentTimeMillis();
        Thread threadFirst = new WorkerString().getCountSpacesToOffer(this.offer);
        Thread threadSecond = new WorkerString().getCountWordsToOffer(this.offer);
        threadFirst.start();
        threadSecond.start();
        while (!threadFirst.isInterrupted() || !threadSecond.isInterrupted()) {
           if (System.currentTimeMillis() - ms >= time) {
               stop(threadFirst);
               stop(threadSecond);
               break;
           }
        }
        System.out.println("End program");
    }
 
    /**
     * If thread is not stop, then stop thread.
     *
     * @param thread - thread for stop;
     */
    public void stop(Thread thread) {
        if (!thread.isInterrupted()) {
            thread.interrupt();
            try {
                thread.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

Добавлено через 3 минуты
а у тебя получается, ты их стартуешь, но обрабатывает их ОС. А сама программа не знает, работают ли они или нет...

Чтоб дождаться результата, нужно запускать цикл и ждать там, когда они завершаться. А если останавливаешь вручную, то нужно отправить им флаг interupted и join ждать, пока завершаться

Добавлено через 2 минуты
а вот пример реализации run в Runnable

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 @Override
    public void run() {
        int index = offer != null ? offer.length() - 1 : -1;
        int countSpaces = 0;
        try {
            while (index >= 0) {
                if (!isInterrupted()) {
                    if (offer.charAt(index) == ' ') {
                        countSpaces++;
                    }
                } else {
                   throw new InterruptedException();
                }
                index--;
            }
            System.out.printf("Count spaces: %d;%sThe thread [%s] is end work.%s", countSpaces, System.lineSeparator(), getName(), System.lineSeparator());
        } catch (InterruptedException e) {
            System.out.printf("The thread [%s] is interrupted.%s", getName(), System.lineSeparator());
        }
    }

Новые блоги и статьи Все статьи Все блоги /
http://iceja.net/ сервер решения полиномов iceja 18.01.2026 Выкатила http:/ / iceja. net/ сервер решения полиномов (находит действительные корни полиномов методом Штурма). На сайте документация по API, но скажу прямо VPS слабенький и 200 000 полиномов. . .	Первый деплой lagorue 16.01.2026 Не спеша развернул своё 1ое приложение в kubernetes. А дальше мне интересно создать 1фронтэнд приложения и 2 бэкэнд приложения развернуть 2 деплоя в кубере получится 2 сервиса и что-бы они. . .	Расчёт переходных процессов в цепи постоянного тока igorrr37 16.01.2026 / * Дана цепь постоянного тока с R, L, C, k(ключ), U, E, J. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа, решает её и находит: токи, напряжения и их 1 и 2 производные при t = 0;. . .	Восстановить юзерскрипты Greasemonkey из бэкапа браузера damix 15.01.2026 Если восстановить из бэкапа профиль Firefox после переустановки винды, то список юзерскриптов в Greasemonkey будет пустым. Но восстановить их можно так. Для этого понадобится консольная утилита. . .
Изучаю kubernetes lagorue 13.01.2026 А пригодятся-ли мне знания kubernetes в России?	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/	WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .

Синхронизация потоков

Решение