java.lang.Object
- kilim.MailboxMPSC<T>

All Implemented Interfaces:

EventPublisher, PauseReason
```
public class MailboxMPSC<T>
extends java.lang.Object
implements PauseReason, EventPublisher
```
This is a typed buffer that supports single producers and a single consumer. It is the basic construct used for tasks to interact and synchronize with each other (as opposed to direct java calls or static member variables). put() and get() are the two essential functions. We use the term "block" to mean thread block, and "pause" to mean fiber pausing. The suffix "nb" on some methods (such as getnb()) stands for non-blocking. Both put() and get() have blocking and non-blocking variants in the form of putb(), putnb

Field Summary

Fields
Modifier and Type	Field	Description
`static Event`	`messageAvailable`
`static int`	`MSG_AVAILABLE`
`(package private) MPSCQueue<T>`	`msgs`
`(package private) VolatileReferenceCell<EventSubscriber>`	`sink`
`static int`	`SPACE_AVAILABLE`
`static Event`	`spaceAvailble`
`(package private) java.util.Queue<EventSubscriber>`	`srcs`
`static int`	`TIMED_OUT`
`static Event`	`timedOut`

Constructor Summary

Constructors
Constructor Description

MailboxMPSC()

MailboxMPSC(int initialSize)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addMsgAvailableListener(EventSubscriber msgSub)`
`void`	`addSpaceAvailableListener(EventSubscriber spcSub)`
`void`	`fill(T[] msg)`
`T`	`get()`
`T`	`get(long timeoutMillis)`
`T`	`get(EventSubscriber eo)`	Non-blocking, nonpausing get.
`T`	`getnb()`	Get, don't pause or block.
`private EventSubscriber`	`getProducer()`
`private long`	`getSize()`
`boolean`	`isValid(Task t)`	True if the given task's reason for pausing is still valid.
`void`	`put(T msg)`	put a non-null message in the mailbox, and pause the calling task until the mailbox has space
`boolean`	`put(T msg, int timeoutMillis)`	put a non-null message in the mailbox, and pause the calling task for timeoutMillis if the mailbox is full.
`boolean`	`put(T msg, EventSubscriber eo)`
`boolean`	`putnb(T msg)`	Attempt to put a message, and return true if successful.
`void`	`removeMsgAvailableListener(EventSubscriber msgSub)`
`void`	`removeSpaceAvailableListener(EventSubscriber spcSub)`
`private boolean`	`srcContains(Task t)`
`java.lang.String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - msgs
```
MPSCQueue<T> msgs
```
  - sink
```
VolatileReferenceCell<EventSubscriber> sink
```
  - srcs
```
java.util.Queue<EventSubscriber> srcs
```
  - SPACE_AVAILABLE
```
public static final int SPACE_AVAILABLE
```
    See Also:
    
    Constant Field Values
  - MSG_AVAILABLE
```
public static final int MSG_AVAILABLE
```
    See Also:
    
    Constant Field Values
  - TIMED_OUT
```
public static final int TIMED_OUT
```
    See Also:
    
    Constant Field Values
  - spaceAvailble
```
public static final Event spaceAvailble
```
  - messageAvailable
```
public static final Event messageAvailable
```
  - timedOut
```
public static final Event timedOut
```
- Constructor Detail
  - MailboxMPSC
```
public MailboxMPSC()
```
  - MailboxMPSC
```
public MailboxMPSC(int initialSize)
```
- Method Detail
  - get
```
public T get(EventSubscriber eo)
```
    Non-blocking, nonpausing get.
    
    Parameters:
    
    eo - . If non-null, registers this observer and calls it with a MessageAvailable event when a put() is done.
    
    Returns:
    
    buffered message if there's one, or null
  - put
```
public boolean put(T msg,
                   EventSubscriber eo)
```
  - getnb
```
public T getnb()
```
    Get, don't pause or block.
    
    Returns:
    
    stored message, or null if no message found.
  - get
```
public T get()
      throws Pausable
```
    Returns:
    
    non-null message.
    
    Throws:
    
    Pausable
  - get
```
public T get(long timeoutMillis)
      throws Pausable
```
    Returns:
    
    non-null message, or null if timed out.
    
    Throws:
    
    Pausable
  - putnb
```
public boolean putnb(T msg)
```
    Attempt to put a message, and return true if successful. The thread is not blocked, nor is the task paused under any circumstance.
  - addSpaceAvailableListener
```
public void addSpaceAvailableListener(EventSubscriber spcSub)
```
  - removeSpaceAvailableListener
```
public void removeSpaceAvailableListener(EventSubscriber spcSub)
```
  - addMsgAvailableListener
```
public void addMsgAvailableListener(EventSubscriber msgSub)
```
  - removeMsgAvailableListener
```
public void removeMsgAvailableListener(EventSubscriber msgSub)
```
  - getProducer
```
private EventSubscriber getProducer()
```
  - srcContains
```
private boolean srcContains(Task t)
```
  - getSize
```
private long getSize()
```
  - put
```
public void put(T msg)
         throws Pausable
```
    put a non-null message in the mailbox, and pause the calling task until the mailbox has space
    
    Throws:
    
    Pausable
  - put
```
public boolean put(T msg,
                   int timeoutMillis)
            throws Pausable
```
    put a non-null message in the mailbox, and pause the calling task for timeoutMillis if the mailbox is full.
    
    Throws:
    
    Pausable
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object
  - isValid
```
public boolean isValid(Task t)
```
    Description copied from interface: PauseReason
    
    True if the given task's reason for pausing is still valid.
    
    Specified by:
    
    isValid in interface PauseReason
  - fill
```
public void fill(T[] msg)
```

Constructors
Constructor	Description
`MailboxMPSC()`
`MailboxMPSC(int initialSize)`

Class MailboxMPSC<T>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

msgs

sink

srcs

SPACE_AVAILABLE

MSG_AVAILABLE

TIMED_OUT

spaceAvailble

messageAvailable

timedOut

Constructor Detail

MailboxMPSC

MailboxMPSC

Method Detail

get

put

getnb

get

get

putnb

addSpaceAvailableListener

removeSpaceAvailableListener

addMsgAvailableListener

removeMsgAvailableListener

getProducer

srcContains

getSize

put

put

toString

isValid

fill