version bump to 3.4.1

Author: mdbergmann

README.md

@@ -783,6 +783,8 @@ Previous 'self' and 'state' parameters are now accessible via `*self*` and `*sta
 
 ### Version history
 
+**Version 3.4.1 (30.01.2025):** More resiliancy in message-box (respawn thread if it was killed).
+
 **Version 3.4.0 (5.10.2024):** Finalized finite-state-machine (FSM) and documentation.
 
 **Version 3.3.3 (1.10.2024):** Bug fix for actor with dispatcher mailbox where the order of processing messages wasn't honoured.

bench.lisp

@@ -201,61 +201,6 @@
                          counter))
               (ac:shutdown system))))))))
 
-
-;; (defun runner-lp ()
-;;   (setf *msgbox* (make-instance 'sento.messageb::message-box-lsr))
-;;   (setf lparallel:*kernel* (lparallel:make-kernel +threads+))
-;;   (setf *counter* 0)
-
-;;   (unwind-protect
-;;        (time
-;;         (let ((chan (lparallel:make-channel)))
-;;           (dotimes (n (max-loop))
-;;             (lparallel:submit-task chan #'msg-submit))
-;;           (dotimes (n (max-loop))
-;;             (lparallel:receive-result chan))))
-;;     (format t "Counter: ~a~%" *counter*)
-;;     (lparallel:end-kernel)
-;;     (sento.messageb::stop *msgbox*)))
-
-;; (defun runner-lp2 ()
-;;   (setf *msgbox* (make-instance 'sento.messageb::message-box-lsr))
-;;   (setf lparallel:*kernel* (lparallel:make-kernel +threads+))
-;;   (setf *counter* 0)
-
-;;   (unwind-protect
-;;        (time
-;;         (progn
-;;           (map nil #'lparallel:force
-;;                (mapcar (lambda (x)
-;;                          (lparallel:future
-;;                            (dotimes (n *per-thread*)
-;;                              (msg-submit))))
-;;                        (mapcar (lambda (n) (format nil "thread-~a" n))
-;;                                (loop for n from 1 to +threads+ collect n))))
-;;           (format t "Counter: ~a~%" *counter*)
-;;           (assert-cond (lambda () (= *counter* (max-loop))) 5)))
-;;     (format t "Counter: ~a~%" *counter*)
-;;     (lparallel:end-kernel)
-;;     (sento.messageb::stop *msgbox*)))
-
-;; (defun runner-lp3 ()
-;;   (setf *msgbox* (make-instance 'sento.messageb::message-box-lsr))
-;;   (setf lparallel:*kernel* (lparallel:make-kernel +threads+))
-;;   (setf *counter* 0)
-
-;;   (unwind-protect
-;;        (time
-;;         (lparallel:pmap nil (lambda (per-thread)
-;;                               (dotimes (n per-thread)
-;;                                 (msg-submit)))
-;;                         :parts 1
-;;                         (loop repeat +threads+ collect *per-thread*)))
-;;     (format t "Counter: ~a~%" *counter*)
-;;     (lparallel:end-kernel)
-;;     (sento.messageb::stop *msgbox*)))
-
-
 (defun run-all (&key
                 (num-iterations 60)
                 (duration 10)
@@ -326,3 +271,61 @@
           (/ (- (get-internal-real-time) started-at)
              internal-time-units-per-second)))
 
+
+;; ----------------------------------
+;; old runner stuff
+;; ----------------------------------
+
+;; (defun runner-lp ()
+;;   (setf *msgbox* (make-instance 'sento.messageb::message-box-lsr))
+;;   (setf lparallel:*kernel* (lparallel:make-kernel +threads+))
+;;   (setf *counter* 0)
+
+;;   (unwind-protect
+;;        (time
+;;         (let ((chan (lparallel:make-channel)))
+;;           (dotimes (n (max-loop))
+;;             (lparallel:submit-task chan #'msg-submit))
+;;           (dotimes (n (max-loop))
+;;             (lparallel:receive-result chan))))
+;;     (format t "Counter: ~a~%" *counter*)
+;;     (lparallel:end-kernel)
+;;     (sento.messageb::stop *msgbox*)))
+
+;; (defun runner-lp2 ()
+;;   (setf *msgbox* (make-instance 'sento.messageb::message-box-lsr))
+;;   (setf lparallel:*kernel* (lparallel:make-kernel +threads+))
+;;   (setf *counter* 0)
+
+;;   (unwind-protect
+;;        (time
+;;         (progn
+;;           (map nil #'lparallel:force
+;;                (mapcar (lambda (x)
+;;                          (lparallel:future
+;;                            (dotimes (n *per-thread*)
+;;                              (msg-submit))))
+;;                        (mapcar (lambda (n) (format nil "thread-~a" n))
+;;                                (loop for n from 1 to +threads+ collect n))))
+;;           (format t "Counter: ~a~%" *counter*)
+;;           (assert-cond (lambda () (= *counter* (max-loop))) 5)))
+;;     (format t "Counter: ~a~%" *counter*)
+;;     (lparallel:end-kernel)
+;;     (sento.messageb::stop *msgbox*)))
+
+;; (defun runner-lp3 ()
+;;   (setf *msgbox* (make-instance 'sento.messageb::message-box-lsr))
+;;   (setf lparallel:*kernel* (lparallel:make-kernel +threads+))
+;;   (setf *counter* 0)
+
+;;   (unwind-protect
+;;        (time
+;;         (lparallel:pmap nil (lambda (per-thread)
+;;                               (dotimes (n per-thread)
+;;                                 (msg-submit)))
+;;                         :parts 1
+;;                         (loop repeat +threads+ collect *per-thread*)))
+;;     (format t "Counter: ~a~%" *counter*)
+;;     (lparallel:end-kernel)
+;;     (sento.messageb::stop *msgbox*)))
+

sento.asd

@@ -1,5 +1,5 @@
 (defsystem "sento"
-  :version "3.4.0"
+  :version "3.4.1"
   :author "Manfred Bergmann"
   :license "Apache-2"
   :description "Actor framework featuring actors and agents for easy access to state and asynchronous operations."