Rosetta Code

Synchronous concurrency: Difference between revisions

Page Discussion

Synchronous concurrency (view source)

Revision as of 00:06, 17 August 2019

58 bytes removed ,  4 years ago
→‎{{header|Racket}}
Line 2,256:
;; 2) Send the total number of lines printed to the Reader thread.
(define (printer)
(thread-send reader-thread
(let loop ([line (thread-receive)][count 0])
(for/sum ([line (in-producer thread-receive eof)])
(if (eof-object? line)
(thread-sendprintf reader-thread"~a\n" countline)
(begin 1)))
(printf "~a\n" line)
(loop (thread-receive) (add1 count))))))
 
;; Start both threads
Anonymous user
Retrieved from "https://rosettacode.org/wiki/Special:MobileDiff/21446"