diff options
author | Christopher Baines <mail@cbaines.net> | 2023-05-02 22:12:46 +0200 |
---|---|---|
committer | Christopher Baines <mail@cbaines.net> | 2023-05-02 22:12:46 +0200 |
commit | 9b274362b3f2f14b124b87324123a39f6687c9ce (patch) | |
tree | 96f2722a9dae883133ff73b3dfc91994fbf4d942 | |
parent | ea79418fcd0d8f849105b65cf2aaabd8f3b24595 (diff) | |
download | build-coordinator-9b274362b3f2f14b124b87324123a39f6687c9ce.tar build-coordinator-9b274362b3f2f14b124b87324123a39f6687c9ce.tar.gz |
Support naming the worker thread channel threads
-rw-r--r-- | guix-build-coordinator/utils/fibers.scm | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/guix-build-coordinator/utils/fibers.scm b/guix-build-coordinator/utils/fibers.scm index 4a7572d..d532960 100644 --- a/guix-build-coordinator/utils/fibers.scm +++ b/guix-build-coordinator/utils/fibers.scm @@ -6,6 +6,8 @@ #:use-module (fibers channels) #:use-module (fibers operations) #:use-module (fibers conditions) + #:use-module ((guix build syscalls) + #:select (set-thread-name)) #:use-module (guix-build-coordinator utils) #:export (make-worker-thread-channel call-with-worker-thread @@ -27,14 +29,23 @@ destructor lifetime (log-exception? (const #t)) - (expire-on-exception? #f)) + (expire-on-exception? #f) + (name "unnamed")) "Return a channel used to offload work to a dedicated thread. ARGS are the arguments of the worker thread procedure." (let ((channel (make-channel))) (for-each - (lambda _ + (lambda (thread-index) (call-with-new-thread (lambda () + (catch 'system-error + (lambda () + (set-thread-name + (string-append + name " w t " + (number->string thread-index)))) + (const #t)) + (let init ((args (initializer))) (parameterize ((%worker-thread-args args)) (let loop ((current-lifetime lifetime)) |