Rosetta Code

Concurrent computing: Difference between revisions

Page Discussion

Concurrent computing (view source)

Revision as of 14:23, 26 July 2021

160 bytes removed ,  2 years ago
m
→‎{{header|Vlang}}: Using vfmt on the code
(→‎{{header|Perl}}: Remove extraneous pasted copy of code)
m (→‎{{header|Vlang}}: Using vfmt on the code)
Line 2,099:
 
fn main() {
words := ["'Enjoy"', "'Rosetta"', "'Code"']
seed_u64 := u64(time.now().unix_time_milli())
q := chan string{}
for i, w in words {
go fn (q chan string, w string, seed_u64 u64) {
mut rng := pcg32.PCG32RNG{}
time_seed := seed.time_seed_array(2)
seed_arr := [u32(seed_u64), u32(seed_u64 >> 32), time_seed[0], time_seed[1]]
rng.seed(seed_arr)
time.sleep(time.Duration(rng.i64n(1_000_000_000)))
q <- w
}(q, w, seed_u64 + u64(i))
}
}
for _ in 0 .. words.len {
println(<-q)
}
}
}</lang>
 
Line 2,124:
 
fn main() {
words := ["'Enjoy"', "'Rosetta"', "'Code"']
mut threads := []thread{} // mutable array to hold the id of the thread
for w in words {
threads << go fn (w string) { // record the
mut rng := pcg32.PCG32RNG{}
time_seed := seed.time_seed_array(4) // the time derived array to seed the random generator
rng.seed(time_seed)
time.sleep(time.Duration(rng.i64n(1_000_000_000)))
println(w)
}(w)
}
}
threads.wait() // join the thread waiting. wait() is defined for threads and arrays of threads
}</lang>
{{out}}<pre>Code
Anonymous user
Retrieved from "https://rosettacode.org/wiki/Special:MobileDiff/21000"