const N = 100000;

var chan = mt::Channel<int>(2)

var produce = mt.start {
	var index = 0;
	io.writeln( "begin producing" )
	while( ++index <= N ){
		if( index % 100 == 0 ) io.writeln( "sending", index )
		chan.send( index )
	}
	io.writeln( "end producing" )
	chan.cap(0)  # set channel buffer size to zero to close the channel;
}

var consume = mt.start {
	io.writeln( "begin consuming" )
	while(1){
		var data = chan.receive()
		if( (int)data.data % 100 == 0 ) io.writeln( "received", data );
		if( data.status == $finished ) break
	}
	io.writeln( "end consuming" )
}