Packages

gleam_otp

0.8.0
1.2.0 1.1.0 1.0.0 1.0.0-rc3 1.0.0-rc2 1.0.0-rc1 0.16.1 0.16.0 0.15.0 0.14.1 0.14.0 0.13.0 0.12.1 0.12.0 0.11.2 0.11.1 0.11.0 0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.3 0.5.2 0.5.1 0.5.0 0.4.0 0.3.1 0.3.0 0.2.0 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.1

Fault tolerant multi-core programs with OTP, the BEAM actor framework.

HexDocs

Current section

Files

Jump to
Readme
38 Versions
2 Dependencies
201 Dependants
Files
Activity
gleam_otp src gleam_otp.gleam
Raw

src/gleam_otp.gleam 

import gleam/io

import gleam/int

import gleam/list

import gleam/otp/task

import gleam/erlang/process.{type Pid}



@external(erlang, "gleam_otp_test_external", "get_message_queue_length")

fn get_message_queue_length(pid pid: Pid) -> Int



fn spawn_task(i) {

  task.async(fn() {

    case i % 500 == 0 {

      True -> io.println("Hello from " <> int.to_string(i))

      False -> Nil

    }

  })

}



pub fn main() {

  io.debug(get_message_queue_length(process.self()))



  list.range(0, 1_000_000)

  |> list.map(spawn_task)

  |> list.each(task.await_forever)



  io.debug(get_message_queue_length(process.self()))

}