X-Git-Url: http://repo.macrolet.net/gitweb/?a=blobdiff_plain;f=src%2Fcode%2Ffinal.lisp;h=c2ef070664eacc010ded303b484315c2b3219cd4;hb=c1aa8b6b5b870f21bc8c81da85708e9d71d4eb93;hp=15a45a6b1dfdbc04e9872161795baf5eb389fc4b;hpb=2a71a27c55ad98e36f2886017d45ca2ae986296d;p=sbcl.git diff --git a/src/code/final.lisp b/src/code/final.lisp index 15a45a6..c2ef070 100644 --- a/src/code/final.lisp +++ b/src/code/final.lisp @@ -13,15 +13,25 @@ (defvar *finalizer-store* nil) -(defvar *finalizer-store-lock* +(defvar *finalizer-store-lock* (sb!thread:make-mutex :name "Finalizer store lock.")) -(defun finalize (object function) - #!+sb-doc +(defmacro with-finalizer-store-lock (&body body) + `(sb!thread::call-with-system-mutex (lambda () ,@body) + *finalizer-store-lock* + t)) + +(defun finalize (object function &key dont-save) + #!+sb-doc "Arrange for the designated FUNCTION to be called when there are no more references to OBJECT, including references in FUNCTION itself. +If DONT-SAVE is true, the finalizer will be cancelled when +SAVE-LISP-AND-DIE is called: this is useful for finalizers +deallocating system memory, which might otherwise be called +with addresses from the old image. + In a multithreaded environment FUNCTION may be called in any thread. In both single and multithreaded environments FUNCTION may be called in any dynamic scope: consequences are unspecified @@ -48,50 +58,55 @@ Examples: (defvar *rec* nil) (defun oops () - (when *rec* + (when *rec* (error \"recursive OOPS\")) (let ((*rec* t)) (gc))) ; or just cons enough to cause one - (progn + (progn (finalize \"oops\" #'oops) (oops)) ; causes GC and re-entry to #'oops due to the finalizer ; -> ERROR, caught, WARNING signalled" - (sb!sys:without-gcing - (sb!thread:with-mutex (*finalizer-store-lock*) - (push (cons (make-weak-pointer object) function) - *finalizer-store*))) + (unless object + (error "Cannot finalize NIL.")) + (with-finalizer-store-lock + (push (list (make-weak-pointer object) function dont-save) + *finalizer-store*)) object) +(defun deinit-finalizers () + ;; remove :dont-save finalizers + (with-finalizer-store-lock + (setf *finalizer-store* (delete-if #'third *finalizer-store*))) + nil) + (defun cancel-finalization (object) #!+sb-doc "Cancel any finalization for OBJECT." ;; Check for NIL to avoid deleting finalizers that are waiting to be ;; run. (when object - (sb!sys:without-gcing - (sb!thread:with-mutex (*finalizer-store-lock*) - (setf *finalizer-store* - (delete object *finalizer-store* - :key (lambda (pair) - (weak-pointer-value (car pair))))))) + (with-finalizer-store-lock + (setf *finalizer-store* + (delete object *finalizer-store* + :key (lambda (list) + (weak-pointer-value (car list)))))) object)) (defun run-pending-finalizers () (let (pending) - (sb!sys:without-gcing - (sb!thread:with-mutex (*finalizer-store-lock*) - (setf *finalizer-store* - (delete-if (lambda (pair) - (when (null (weak-pointer-value (car pair))) - (push (cdr pair) pending) - t)) - *finalizer-store*)))) + (with-finalizer-store-lock + (setf *finalizer-store* + (delete-if (lambda (list) + (when (null (weak-pointer-value (car list))) + (push (second list) pending) + t)) + *finalizer-store*))) ;; We want to run the finalizer bodies outside the lock in case ;; finalization of X causes finalization to be added for Y. (dolist (fun pending) (handler-case - (funcall fun) - (error (c) - (warn "Error calling finalizer ~S:~% ~S" fun c))))) + (funcall fun) + (error (c) + (warn "Error calling finalizer ~S:~% ~S" fun c))))) nil)