Synchronous concurrency: Difference between revisions

Content added Content deleted

Inline

@@ Line 1,139: / Line 1,139: @@
 {{out}}
 <pre>
 \ synco.fs	Synchronous concurrency for RosettaCode
 include co.fs
@@ Line 1,162: / Line 1,161: @@
 	REPEAT	DROP
 	Line DUP CHAN 2!
-	CO
+	\ -- Wait for report back
+	BEGIN CO CHAN CHAN? UNTIL
+	\ -- Have it, show and go
 	CR S" -------" TYPE
 	CR S" LINES: " TYPE CHAN @ ?
@@ Line 1,179: / Line 1,182: @@
 		CO
 	REPEAT
-X CHAN 2!
+	\ -- Chance to stop other writers
 	CO
+	\ -- First of writers reports back
+	\ -- the shared global counter
+	CHAN CHAN? 0=
+	IF
+X CHAN 2!
+		CO
+	THEN
 ;
 \
 \ * RUNNER
 \
-READER WRITER GO CR BYE
+READER WRITER ( WRITER WRITER :-) GO CR BYE
 -------
-LINES: 46
+LINES: 59
 </pre>