threads_test.ooc

import structs/ArrayList
import threading/Thread

counter := 0

mutex := Mutex new()

threads := ArrayList<Thread> new()
main: func {
  for (i in 0..10) {
    threads add(Thread new(||
      for (i in 0..1000) {
        mutex lock()
        counter += 1   
        mutex unlock()
        Thread yield()
      }
    ))
  }

  for (t in threads) t start()
  for (t in threads) t wait()

  // prints counter = ???
  "counter = %d" printfln(counter)
}