|
45
|
1 package jp.ac.u_ryukyu.ie.cr.shoshi.jungle.transaction;
|
|
|
2
|
|
|
3 import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
4 import java.util.concurrent.atomic.AtomicReference;
|
|
|
5
|
|
|
6 public class AtomicReservableReference<V>
|
|
|
7 {
|
|
|
8 public static void main(String _args[])
|
|
|
9 {
|
|
|
10 String hoge = "hoge";
|
|
|
11 String fuga = "fuga";
|
|
|
12 AtomicReservableReference<String> arr = new AtomicReservableReference<String>(hoge);
|
|
|
13 AtomicReservableReference<String>.Reservation r1 = arr.makeReservation(hoge,fuga);
|
|
81
|
14 //AtomicReservableReference<String>.Reservation r2 = arr.makeReservation(hoge,fuga);
|
|
45
|
15
|
|
|
16 System.out.println(arr.get());
|
|
|
17 r1.confirm();
|
|
|
18 System.out.println(arr.get());
|
|
|
19 }
|
|
|
20
|
|
|
21 private AtomicReference<Reservation> reservation;
|
|
|
22 private AtomicBoolean flagReservation;
|
|
|
23
|
|
|
24 public AtomicReservableReference(V _ref)
|
|
|
25 {
|
|
|
26 reservation = new AtomicReference<Reservation>(new Reservation(_ref,null,true));
|
|
|
27 flagReservation = new AtomicBoolean(false);
|
|
|
28 }
|
|
|
29
|
|
|
30 public Reservation makeReservation(V _expect,V _update)
|
|
|
31 {
|
|
|
32 if(flagReservation.compareAndSet(false,true)){
|
|
|
33 V value = get();
|
|
|
34 if(value == _expect){
|
|
|
35 Reservation expect = reservation.get();
|
|
|
36 return new Reservation(_update,expect,false);
|
|
|
37 }
|
|
|
38 flagReservation.set(false);
|
|
|
39 }
|
|
|
40
|
|
|
41 return null;
|
|
|
42 }
|
|
|
43
|
|
|
44 public void set(V _value)
|
|
|
45 {
|
|
|
46 reservation.set(new Reservation(_value,null,true));
|
|
|
47 }
|
|
|
48
|
|
132
|
49 public Reservation getReservation(){
|
|
|
50 return reservation.get();
|
|
|
51 }
|
|
|
52
|
|
45
|
53 public V get()
|
|
|
54 {
|
|
|
55 Reservation r = reservation.get();
|
|
|
56 return r.get();
|
|
|
57 }
|
|
|
58
|
|
|
59 public class Reservation
|
|
|
60 {
|
|
|
61 public final Reservation expect;
|
|
|
62 public final AtomicReference<V> ref;
|
|
|
63 public final AtomicBoolean flagConfirmed;
|
|
|
64
|
|
|
65 public Reservation(V _object,Reservation _expect,boolean _confirmed)
|
|
|
66 {
|
|
|
67 expect = _expect;
|
|
|
68 ref = new AtomicReference<V>(_object);
|
|
|
69 flagConfirmed = new AtomicBoolean(_confirmed);
|
|
|
70 }
|
|
|
71
|
|
132
|
72 public void set(V object){
|
|
|
73 ref.set(object);
|
|
|
74 }
|
|
|
75
|
|
45
|
76 public V get()
|
|
|
77 {
|
|
|
78 return ref.get();
|
|
|
79 }
|
|
|
80
|
|
|
81 public void confirm()
|
|
|
82 {
|
|
|
83 if(flagConfirmed.compareAndSet(false,true)){
|
|
|
84 if(reservation.compareAndSet(expect,this) == false){
|
|
|
85 throw new IllegalStateException("foo!");
|
|
|
86 }
|
|
|
87 flagReservation.set(false);
|
|
|
88 }
|
|
|
89 }
|
|
|
90
|
|
|
91 public void cancel()
|
|
|
92 {
|
|
|
93 if(flagConfirmed.compareAndSet(false,true)){
|
|
|
94 flagReservation.set(true);
|
|
|
95 }
|
|
|
96 }
|
|
|
97 }
|
|
|
98 }
|
