Module Java.util.Concurrent

Java classes from package java.util.concurrent

Imports

• import frege.Prelude as Prelude
• import Prelude.PreludeArrays as PreludeArrays
• import Prelude.PreludeBase as PreludeBase
• import Prelude.PreludeDecimal as PreludeDecimal
• import Prelude.PreludeIO as PreludeIO
• import Prelude.PreludeList as PreludeList
• import Prelude.PreludeMonad as PreludeMonad
• import Prelude.PreludeText as PreludeText
• import Java.util.Regex as Regexp
• import Java.Util as Util

Table of Content

• Definitions

  data ArrayBlockingQueue e = native java.util.concurrent.ArrayBlockingQueue

  data BlockingQueue e = native java.util.concurrent.BlockingQueue

  data ExecutorService = native java.util.concurrent.ExecutorService

  data RejectedExecutionException = pure native java.util.concurrent.RejectedExecutionException

• Instances

  instance Exceptional RejectedExecutionException

• Functions and Values by Type

Definitions

data RejectedExecutionException = pure native java.util.concurrent.RejectedExecutionException

Thrown when a task is submitted to an ExecutorService that was shut down or whose queue is full.

data BlockingQueue e = native java.util.concurrent.BlockingQueue

Member Functions

add ∷ MutableIO (BlockingQueue e) → e → IO Bool
native add  throws IllegalStateException

add element to blocking queue, throw exception if not possible

offer ∷ MutableIO (BlockingQueue e) → e → IO Bool
native offer

add element to blocking queue, return false if not possible

poll ∷ MutableIO (BlockingQueue e) → IO (Maybe e)
native poll

get and remove element from blocking queue, return null if it is empty

put ∷ MutableIO (BlockingQueue e) → e → IO ()
native put  throws InterruptedException

add element to blocking queue, block until possible

remove ∷ MutableIO (BlockingQueue e) → IO e
native remove  throws NoSuchElementException

get and remove element from blocking queue, throw exception if it is empty

take ∷ MutableIO (BlockingQueue e) → IO e
native take  throws InterruptedException

get and remove element from blocking queue, block until something is available

data ArrayBlockingQueue e = native java.util.concurrent.ArrayBlockingQueue

Member Functions

new ∷ Int → STMutable RealWorld (ArrayBlockingQueue e)
     | Int → Bool → STMutable RealWorld (ArrayBlockingQueue e)
native new

Creates an ArrayBlockingQueue with the given (fixed) capacity and the specified access policy.

If the Bool argument is missing, the default access policy is used. If it is true then queue accesses for threads blocked on insertion or removal, are processed in FIFO order; otherwise the access order is unspecified.

The capacity must be greater than 0, otherwise an IllegalArgumentException is thrown.

new𝖆 ∷ Int → STMutable RealWorld (ArrayBlockingQueue e)
native new  overloads new

Creates an ArrayBlockingQueue with the given (fixed) capacity and the specified access policy.

If the Bool argument is missing, the default access policy is used. If it is true then queue accesses for threads blocked on insertion or removal, are processed in FIFO order; otherwise the access order is unspecified.

The capacity must be greater than 0, otherwise an IllegalArgumentException is thrown.

new𝖇 ∷ Int → Bool → STMutable RealWorld (ArrayBlockingQueue e)
native new  overloads new

Creates an ArrayBlockingQueue with the given (fixed) capacity and the specified access policy.

If the Bool argument is missing, the default access policy is used. If it is true then queue accesses for threads blocked on insertion or removal, are processed in FIFO order; otherwise the access order is unspecified.

The capacity must be greater than 0, otherwise an IllegalArgumentException is thrown.

data ExecutorService = native java.util.concurrent.ExecutorService

The Java executor service interface.

Member Functions

executorService ∷ () → STMutable RealWorld ExecutorService
native frege.run.Concurrent.executorService

The default executor service of the Frege runtime

isShutdown ∷ MutableIO ExecutorService → IO Bool
native isShutdown

Tells if this executor has been shut down.

isTerminated ∷ MutableIO ExecutorService → IO Bool
native isTerminated

Tells if all tasks have completed after ExecutorService.shutdown.

shutdown ∷ MutableIO ExecutorService → IO ()
native shutdown

Initiates an orderly shutdown in which previously submitted tasks are executed, but no new tasks will be accepted.

submit ∷ MutableIO ExecutorService → MutableIO Runnable → IO ()
native submit  throws RejectedExecutionException

Submit a Runnable for execution.

Note that unlike in Java, no Future is returned.

Instances

instance Exceptional RejectedExecutionException

Member Functions

javaClass ∷ Class RejectedExecutionException
pure native java.util.concurrent.RejectedExecutionException.class

Functions and Values by Type

MutableIO ExecutorService → MutableIO Runnable → IO ()

ExecutorService.submit

MutableIO ExecutorService → IO ()

ExecutorService.shutdown

MutableIO ExecutorService → IO Bool

ExecutorService.isTerminated, ExecutorService.isShutdown

() → STMutable RealWorld ExecutorService

ExecutorService.executorService

Class RejectedExecutionException

Exceptional_RejectedExecutionException.javaClass

MutableIO (BlockingQueue e) → e → IO ()

BlockingQueue.put

MutableIO (BlockingQueue e) → e → IO Bool

BlockingQueue.add, BlockingQueue.offer

MutableIO (BlockingQueue e) → IO (Maybe e)

BlockingQueue.poll

MutableIO (BlockingQueue e) → IO e

BlockingQueue.take, BlockingQueue.remove

Int → Bool → STMutable RealWorld (ArrayBlockingQueue e)

ArrayBlockingQueue.new𝖇

Int → STMutable RealWorld (ArrayBlockingQueue e)

ArrayBlockingQueue.new𝖆

ω

ArrayBlockingQueue.new