File tree 3 files changed +18
-9
lines changed
3 files changed +18
-9
lines changed Original file line number Diff line number Diff line change 139
139
140
140
(counter :name :my-counter )
141
141
(send :my-counter 1 )
142
- (print " asking" )
143
- (force-output )
144
142
(is (= 3 (ask :my-counter 2 )))
145
- (print " joining" )
146
- (force-output )
147
143
(close-and-join-actors :my-counter )
148
- (print " checking" )
149
- (force-output )
150
144
(is (eql nil (gethash :my-counter *registry* ))))
Original file line number Diff line number Diff line change 37
37
(counter :name :my-counter :workers 2 )
38
38
(send :my-counter 1 )
39
39
(is (ask :my-counter 1 ))
40
- (close-actor :my-counter ))
40
+ (join-actor (close-actor :my-counter )))
41
+
42
+ (deftest test-dispatcher-redefine ()
43
+ (define-actor counter ((c 0 )) (increment)
44
+ (incf c increment))
45
+
46
+ (counter :name :my-counter :workers 2 )
47
+ (ask :my-counter 1 )
48
+ (ask :my-counter 1 )
49
+
50
+ (define-actor counter ((c 0 )) (increment)
51
+ (incf c (* 2 increment)))
52
+
53
+ (send :my-counter 1 )
54
+ (send :my-counter 1 )
55
+ (is (= 6 (reduce #' + (join-actor (close-actor :my-counter ))))))
Original file line number Diff line number Diff line change 79
79
(dolist (worker (dispatcher-workers actor))
80
80
(close-actor worker))
81
81
(setf (dispatcher-openp actor) nil )
82
+ (remhash (dispatcher-name actor) *registry* )
82
83
actor)
83
84
(:method ((actor t ))
84
85
(close-actor (resolve-actor actor))))
89
90
(bt2 :join-thread (actor-thread actor))
90
91
(apply #' values (actor-store actor)))
91
92
(:method ((actor dispatcher))
92
- (prog1 (mapcar #' join-actor (dispatcher-workers actor))
93
- (remhash (dispatcher-name actor) *registry* )))
93
+ (mapcar #' join-actor (dispatcher-workers actor)))
94
94
(:method ((actor t ))
95
95
(join-actor (resolve-actor actor))))
96
96
You can’t perform that action at this time.
0 commit comments