From f9f106ee4d962b1245e0d7d27823050382828ea7 Mon Sep 17 00:00:00 2001 From: Justin Ethier Date: Fri, 28 Jun 2019 13:34:02 -0400 Subject: [PATCH] Use integrated lib --- libs/cyclone/use-shared-queue.scm | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) diff --git a/libs/cyclone/use-shared-queue.scm b/libs/cyclone/use-shared-queue.scm index ccc23a80..ca03f69a 100644 --- a/libs/cyclone/use-shared-queue.scm +++ b/libs/cyclone/use-shared-queue.scm @@ -2,16 +2,15 @@ (import (scheme base) (scheme write) - (shared-queue) (srfi 18) (cyclone concurrent)) -(define q (make-queue)) +(define q (make-shared-queue)) (define (consume) (%consume) (%consume)) (define (%consume) - (let ((val (queue-remove! q))) + (let ((val (shared-queue-remove! q))) (if (procedure? val) (set! val (val))) (write `(removed ,val ,(current-thread))) @@ -25,11 +24,11 @@ (thread-start! t2) (thread-sleep! 1) -(queue-add! q 'a) -(queue-add! q (lambda () (+ 1 2 3))) -(queue-add! q 'c) -(queue-add! q 'd) -(queue-add! q 'e) +(shared-queue-add! q 'a) +(shared-queue-add! q (lambda () (+ 1 2 3))) +(shared-queue-add! q 'c) +(shared-queue-add! q 'd) +(shared-queue-add! q 'e) (thread-join! t1) (thread-join! t2)