VPF::Java Concurrency. Как заблокироваться по объекту.

w3xgamer

Дата 4.10.2020, 15:14 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 1
Регистрация: 4.10.2020

Репутация: нет
Всего: нет

Здравствуйте.
Подскажите, пожалуйста, по многопоточности и блокировкам.

Вот есть код

код Java

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:

63:

64:

65:

66:

67:

68:

69:

70:

71:

72:

73:

74:

75:

76:

77:

78:

79:

80:

81:

82:

83:

84:

85:

86:

87:

88:

89:

90:

91:

92:

93:

94:

95:

package org.study.java.concurrency;

import java.util.concurrent.*;

import java.util.concurrent.atomic.AtomicLong;

class SomeDataClass {

private final AtomicLong number1;

private final AtomicLong number2;

public SomeDataClass(Long number1, Long number2) {

this.number1 = new AtomicLong(number1);

this.number2 = new AtomicLong(number2);

}

public synchronized void NextStep() {

synchronized (this) {

this.setNumber1(getNumber1() + 1);

this.setNumber2(getNumber2() + 1);

}

Thread.yield();

}

public synchronized Long getNumber1() {

return number1.get();

}

public synchronized Long getNumber2() {

return number2.get();

}

public synchronized void setNumber1(Long number1) {

this.number1.set(number1);

}

public synchronized void setNumber2(Long number2) {

this.number2.set(number2);

}

class ProcessRunner implements Runnable {

private final SomeDataClass dataClass;

public ProcessRunner(SomeDataClass dataClass) {

this.dataClass = dataClass;

System.out.println("CameDataClass to ProcessRunner = " + dataClass);

System.out.println("With values, number1 = " + dataClass.getNumber1() + ", number2 = " + dataClass.getNumber2());

}

@Override

public void run() {

while (true) {

dataClass.NextStep();

}

class ProcessChecker implements Runnable {

private final SomeDataClass dataClass;

public ProcessChecker(SomeDataClass dataClass) {

this.dataClass = dataClass;

System.out.println("Came dataclass to process checker = " + dataClass);

System.out.println("With values, number1 = " + dataClass.getNumber1() + ", number2 = " + dataClass.getNumber2());

}

@Override

public void run() {

try {

while (true) {

System.out.println("DataClass = " + dataClass + ", CurrentNumber1 = " + dataClass.getNumber1() + ", CurrentNumber2 = " + dataClass.getNumber2());

TimeUnit.SECONDS.sleep(2);

}

} catch (InterruptedException e) {

e.printStackTrace();

}

public class ConcurrencyExample {

public static void main(String[] args) {

ExecutorService executorService = Executors.newCachedThreadPool();

SomeDataClass dataClass = new SomeDataClass(1L, 1L);

executorService.submit(new ProcessRunner(dataClass));

executorService.submit(new ProcessChecker(dataClass));

executorService.shutdown();

}

Идея этого кода в том, что создаются два параллельных потока, и в эти потоки передается один и тот же объект. Один поток постоянно изменяет его состояние, а второй поток выводит его содержимое. Он одновременно увеличивает на единицу значение двух переменных, но при выводе на экран мы видим что их значения различаются.

Вот, сейчас вывод примерно такой.

Без подсветки

10:

CameDataClass to ProcessRunner = org.study.java.concurrency.SomeDataClass@266474c2

With values, number1 = 1, number2 = 1

Came dataclass to process checker = org.study.java.concurrency.SomeDataClass@266474c2

With values, number1 = 177, number2 = 180

DataClass = org.study.java.concurrency.SomeDataClass@266474c2, CurrentNumber1 = 1024, CurrentNumber2 = 1026

DataClass = org.study.java.concurrency.SomeDataClass@266474c2, CurrentNumber1 = 2787500, CurrentNumber2 = 2787531

DataClass = org.study.java.concurrency.SomeDataClass@266474c2, CurrentNumber1 = 5828168, CurrentNumber2 = 5828509

DataClass = org.study.java.concurrency.SomeDataClass@266474c2, CurrentNumber1 = 8834895, CurrentNumber2 = 8837607

Process finished with exit code 130 (interrupted by signal 2: SIGINT)

Есть вариант решения этой проблемы через synchronized вот так

код Java

synchronized (dataClass) {

System.out.println("DataClass = " + dataClass + ", CurrentNumber1 = " + dataClass.getNumber1() + ", CurrentNumber2 = " + dataClass.getNumber2());

TimeUnit.SECONDS.sleep(2);

}

Но мне интересно как можно решить ту же самую проблему с помощью Lock и ReentrantLock?

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »