O
Size: a a a
2020 July 04
AS
Надо подождать, пока два треда отработают
Вот, а как это подождать?
AS
Thread 1: a[0] = 1;
Thread 2: a[1] = 1;
Thread 3: thread1.join(); thread2.join(); print(a[0] + a[1]); // гарантированно печатает "2"
Thread 2: a[1] = 1;
Thread 3: thread1.join(); thread2.join(); print(a[0] + a[1]); // гарантированно печатает "2"
か
Thread 1: a[0] = 1;
Thread 2: a[1] = 1;
Thread 3: thread1.join(); thread2.join(); print(a[0] + a[1]); // гарантированно печатает "2"
Thread 2: a[1] = 1;
Thread 3: thread1.join(); thread2.join(); print(a[0] + a[1]); // гарантированно печатает "2"
Угу
AS
С точки зрения JMM -- Thread.join есть synchronized action, связывающее с последним действием в потоке, так што...
AS
Дальше, из соображений про цепочки release-acquire:
Thread 1: a[0] = 1; future1.set(true);
Thread 2: a[1] = 1; future2.set(true);
Thread 3: future1.get(); future2.get(); print(a[0] + a[1]); // гарантированно печатает "2"
Так, в принципе, с передачей данных туда-сюда работают практически все пулы потоков.
Thread 1: a[0] = 1; future1.set(true);
Thread 2: a[1] = 1; future2.set(true);
Thread 3: future1.get(); future2.get(); print(a[0] + a[1]); // гарантированно печатает "2"
Так, в принципе, с передачей данных туда-сюда работают практически все пулы потоков.
AS
По абсолютно тем же причинам (release-acquire) работает
volatile boolean thread1Done, thread2Done;
Thread 1: a[0] = 1; thread1Done = true;
Thread 2: a[1] = 1; thread2Done = true;
Thread 3: while(!thread1Done); while(!thread2Done); print(a[0] + a[1]); // гарантированно печатает "2"
volatile boolean thread1Done, thread2Done;
Thread 1: a[0] = 1; thread1Done = true;
Thread 2: a[1] = 1; thread2Done = true;
Thread 3: while(!thread1Done); while(!thread2Done); print(a[0] + a[1]); // гарантированно печатает "2"
AS
Равно как работает без волатайлов, но с локами:
boolean thread1Done, thread2Done;
final Object lock = new Object();
Thread 1: a[0] = 1; synchronized(lock) { thread1Done = true; lock.notifyAll(); }
Thread 2: a[1] = 1; synchronized(lock) { thread2Done = true; lock.notifyAll(); }
Thread 3: synchronized(lock) { while (!thread1Done || !thread2Done) lock.wait(); }; print(a[0] + a[1]); // гарантированно печатает "2"
boolean thread1Done, thread2Done;
final Object lock = new Object();
Thread 1: a[0] = 1; synchronized(lock) { thread1Done = true; lock.notifyAll(); }
Thread 2: a[1] = 1; synchronized(lock) { thread2Done = true; lock.notifyAll(); }
Thread 3: synchronized(lock) { while (!thread1Done || !thread2Done) lock.wait(); }; print(a[0] + a[1]); // гарантированно печатает "2"
O
Равно как работает без волатайлов, но с локами:
boolean thread1Done, thread2Done;
final Object lock = new Object();
Thread 1: a[0] = 1; synchronized(lock) { thread1Done = true; lock.notifyAll(); }
Thread 2: a[1] = 1; synchronized(lock) { thread2Done = true; lock.notifyAll(); }
Thread 3: synchronized(lock) { while (!thread1Done || !thread2Done) lock.wait(); }; print(a[0] + a[1]); // гарантированно печатает "2"
boolean thread1Done, thread2Done;
final Object lock = new Object();
Thread 1: a[0] = 1; synchronized(lock) { thread1Done = true; lock.notifyAll(); }
Thread 2: a[1] = 1; synchronized(lock) { thread2Done = true; lock.notifyAll(); }
Thread 3: synchronized(lock) { while (!thread1Done || !thread2Done) lock.wait(); }; print(a[0] + a[1]); // гарантированно печатает "2"
только в первом будет параллельная работа
AS
только в первом будет параллельная работа
в каком смысле? в примере с локами лок берётся только для выставления флагов и нотификации ;)
O
в каком смысле? в примере с локами лок берётся только для выставления флагов и нотификации ;)
а, точно, не заметил
AS
общий паттерн видите?
Thread 1: a[0] = 1; <RELEASE 1>
Thread 2: a[1] = 1; <RELEASE 2>
Thread 3: <ACQUIRE 1> <ACQUIRE 2> print(a[0] + a[1]); // гарантированно печатает "2"
Вся дичь с локами не обязана вылезать за рамки release/acquire ;)
Thread 1: a[0] = 1; <RELEASE 1>
Thread 2: a[1] = 1; <RELEASE 2>
Thread 3: <ACQUIRE 1> <ACQUIRE 2> print(a[0] + a[1]); // гарантированно печатает "2"
Вся дичь с локами не обязана вылезать за рамки release/acquire ;)