The Computer Language
Benchmarks Game

thread-ring F# Mono LLVM #2 program

source code

(*  The Computer Language Benchmarks Game

    Contributed by Dmitry Lomov & Jomo Fisher

    Uses F# asyncs (lightweight threads) with customized auto reset cell 
    as semaphore.

let ringLength = 503

type AutoResetCell() =
    let mutable value = -1
    let mutable run = None
    member this.RegisterResult res =
        let grabbed = 
            lock this (fun () ->
                match run with
                | None -> value <- res; None
                | grabbed -> run <- None; grabbed)
        match grabbed with
        | None -> ()
        | Some run -> run res

    member this.AsyncResult = 
        Async.FromContinuations(fun (success,_,_) -> 
            let runNow = 
                lock this (fun () ->
                    if value = -1 then
                        run <- Some success
                    else true)                        
            if runNow then 
                let r = value
                value <- -1 // Autoreset
                success r) 

let createCell _ = AutoResetCell()

let createThread (cells:AutoResetCell array) i =
    let next = if i = ringLength-1 then 0 else i + 1
    async {
            let more = ref true
            while !more do
                let! msg = cells.[i].AsyncResult 
                more := msg>0
                if msg = 0 then                    
                    printfn "%d" (i+1) }

let main args = 
    let count = if args.Length>0 then int args.[0] else 50000000
    let cells = Array.init ringLength createCell

    let threads = Array.init ringLength (createThread cells)


        |> Async.Parallel // Run all the asyncs at once
        |> Async.Ignore // Ignore the results
        |> Async.RunSynchronously // Block the main thread until work is done

notes, command-line, and program output

32-bit Ubuntu one core
F# Compiler for F# 4.0 (Open Source Edition)
Mono JIT compiler version 4.5.1 (master/3e844dd Fri May  6 19:24:07 PDT 2016)
	LLVM:          yes(3.6.0svn-mono-master/9f79399)
	GC:            sgen

Sat, 07 May 2016 20:06:06 GMT

mv threadring.fsharp-2.fsharp threadring.fsharp-2.fs
/usr/local/bin/fsharpc --target:exe --platform:x86 -O  -o threadring.fsharp-2.fsharp_run.exe threadring.fsharp-2.fs
F# Compiler for F# 4.0 (Open Source Edition)
Freely distributed under the Apache 2.0 Open Source License

/home/dunham/benchmarksgame_onecore/threadring/tmp/threadring.fsharp-2.fs(10,1): warning FS0221: The declarations in this file will be placed in an implicit module 'Threadring.fsharp-2' based on the file name 'threadring.fsharp-2.fs'. However this is not a valid F# identifier, so the contents will not be accessible from other files. Consider renaming the file or adding a 'module' or 'namespace' declaration at the top of the file.
rm threadring.fsharp-2.fs
4.71s to complete and log all make actions

/usr/local/bin/mono --llvm --gc=sgen threadring.fsharp-2.fsharp_run.exe 50000000