// xfail for now, due to some problem with polymorphic types. use std; import std::task; import std::task::task_id; import std::comm; import std::comm::_chan; import std::comm::send; fn main() { log "===== WITHOUT THREADS ====="; test00(); } fn test00_start(ch: _chan, message: int, count: int) { log "Starting test00_start"; let i: int = 0; while i < count { log "Sending Message"; send(ch, message + 0); i = i + 1; } log "Ending test00_start"; } fn test00() { let number_of_tasks: int = 16; let number_of_messages: int = 4; log "Creating tasks"; let po = comm::mk_port(); let ch = po.mk_chan(); let i: int = 0; // Create and spawn tasks... let tasks = []; while i < number_of_tasks { tasks += [task::_spawn(bind test00_start(ch, i, number_of_messages))]; i = i + 1; } // Read from spawned tasks... let sum = 0; for t: task_id in tasks { i = 0; while i < number_of_messages { let value = po.recv(); sum += value; i = i + 1; } } // Join spawned tasks... for t: task_id in tasks { task::join_id(t); } log "Completed: Final number is: "; log_err sum; // assert (sum == (((number_of_tasks * (number_of_tasks - 1)) / 2) * // number_of_messages)); assert (sum == 480); }