MyNixOS website logo
Description

Concurrent Chans as read/write pairs. Also provides generic Chan pair class.

An implementation of concurrent channels identical to Control.Concurrent.Chan, except that the channel is represented as a pair, one of which allows only read operations, the other write operations.

This makes code easier to reason about (the types strictly delegate read/write permission), suggests useful instances (e.g. Functor and Contravariant are easily defined) on the chan pairs, and simplifies the API.

Furthermore this allows messages sent to channels with no readers to be trivially garbage-collected, without relying on inlining optimizations.

We also provide a module that defines a class SplitChan which defines the basic methods any pair of Chan types should provide, allowing easy swapping of Chan implementations.

To use standard Chans with these polymorphic functions, import as follows:

import Control.Concurrent.Chan hiding (readChan,writeChan,writeList2Chan)
import Control.Concurrent.Chan.Class

When used alongside standard Chans, the Split module can be imported qualified like:

import qualified Control.Concurrent.Chan.Split as S

Its interface is mostly backwards compatible with Chan. Note, we do not implement the deprecated unGetChan and isEmptyChan functions.

This module is used internally by the "simple-actors" package.

CHANGES: 0.4.0 -> 0.5.0

  • modify TChan v2.4 code into split version

  • depend on STM

  • clean up Extensions section and broken links

Metadata

Version

0.5.0

Platforms (75)

    Darwin
    FreeBSD
    Genode
    GHCJS
    Linux
    MMIXware
    NetBSD
    none
    OpenBSD
    Redox
    Solaris
    WASI
    Windows
Show all
  • aarch64-darwin
  • aarch64-genode
  • aarch64-linux
  • aarch64-netbsd
  • aarch64-none
  • aarch64_be-none
  • arm-none
  • armv5tel-linux
  • armv6l-linux
  • armv6l-netbsd
  • armv6l-none
  • armv7a-darwin
  • armv7a-linux
  • armv7a-netbsd
  • armv7l-linux
  • armv7l-netbsd
  • avr-none
  • i686-cygwin
  • i686-darwin
  • i686-freebsd
  • i686-genode
  • i686-linux
  • i686-netbsd
  • i686-none
  • i686-openbsd
  • i686-windows
  • javascript-ghcjs
  • loongarch64-linux
  • m68k-linux
  • m68k-netbsd
  • m68k-none
  • microblaze-linux
  • microblaze-none
  • microblazeel-linux
  • microblazeel-none
  • mips-linux
  • mips-none
  • mips64-linux
  • mips64-none
  • mips64el-linux
  • mipsel-linux
  • mipsel-netbsd
  • mmix-mmixware
  • msp430-none
  • or1k-none
  • powerpc-netbsd
  • powerpc-none
  • powerpc64-linux
  • powerpc64le-linux
  • powerpcle-none
  • riscv32-linux
  • riscv32-netbsd
  • riscv32-none
  • riscv64-linux
  • riscv64-netbsd
  • riscv64-none
  • rx-none
  • s390-linux
  • s390-none
  • s390x-linux
  • s390x-none
  • vc4-none
  • wasm32-wasi
  • wasm64-wasi
  • x86_64-cygwin
  • x86_64-darwin
  • x86_64-freebsd
  • x86_64-genode
  • x86_64-linux
  • x86_64-netbsd
  • x86_64-none
  • x86_64-openbsd
  • x86_64-redox
  • x86_64-solaris
  • x86_64-windows