Revision as of 22:30, 5 June 2016 (view source) Kazinator (talk \| contribs) m (→‎{{header\|TXR}}: Fix lang tag.) ← Older edit		Revision as of 17:46, 6 July 2016 (view source) Franck (talk \| contribs) m (→‎{{header\|Oforth}}) Newer edit →
Line 1,519: When the file has been read and sent to channel chPrint, this channel is closed. All tasks waiting for an object in this channel are released and receive null. Then printing task returns number of printed lines into chCount channel for the main task. <lang Oforth>~~func~~import: ~~printing(chPrint, chCount)~~parallel { 0 while(chPrint receive dup notNull) [ println 1 + ] drop▼ chCount send drop▼ } : printing(chPrint, chCount) func: concurrentPrint(aFileName)▼ ▲ 0 while( chPrint receive dup notNull ) [ println 1 + ] drop { ▲ chCount send drop ; ▲~~func~~: concurrentPrint(aFileName) \| chPrint chCount line \| Channel new ->chPrint Line 1,533 ⟶ 1,532: #[ printing(chPrint, chCount) ] & ~~File newMode(~~aFileName, File~~.UTF8)~~ new forEach: line [ chPrint send(line) drop ] chPrint close chCount receive "Number of lines printed : " print println ;</lang> ~~}</lang>~~ =={{header\|ooRexx}}==

Synchronous concurrency (view source)