Uses of Class
kilim.Pausable

Packages that use Pausable

Package	Description
kilim
kilim.concurrent
kilim.examples
kilim.http
kilim.nio
kilim.support

Uses of Pausable in kilim

Methods in kilim that throw Pausable

Modifier and Type	Method	Description
static <XX,E1 extends java.lang.Throwable,E2 extends java.lang.Throwable> XX	Pausable.apply(XX obj, Pausable.Psumer<XX,E1> func1, Pausable.Psumer<XX,E2> func2)
static <XX,E1 extends java.lang.Throwable,E2 extends java.lang.Throwable,E3 extends java.lang.Throwable> XX	Pausable.apply(XX obj, Pausable.Psumer<XX,E1> func1, Pausable.Psumer<XX,E2> func2, Pausable.Psumer<XX,E3> func3)
static <XX,EE extends java.lang.Throwable> XX	Pausable.apply(XX obj, Pausable.Psumer<XX,EE> func)
YY	Pausable.Pfun.apply(XX obj)
void	Pausable.Psumer.apply(XX obj)
static <XX,EE extends java.lang.Throwable> XX	Pausable.applyAll(XX obj, Pausable.Psumer<XX,EE>... funcs)
static <X1,X2,X3,X4,E1 extends java.lang.Throwable,E2 extends java.lang.Throwable,E3 extends java.lang.Throwable> X4	Pausable.chain(X1 obj, Pausable.Pfun<X1,X2,E1> function1, Pausable.Pfun<X2,X3,E2> function2, Pausable.Pfun<X3,X4,E3> function3)
static <X1,X2,ZZ,E1 extends java.lang.Throwable,E2 extends java.lang.Throwable> ZZ	Pausable.chain(X1 obj, Pausable.Pfun<X1,X2,E1> function1, Pausable.Pfun<X2,ZZ,E2> function2)
static <XX,YY,EE extends java.lang.Throwable> YY	Pausable.chain(XX obj, Pausable.Pfun<XX,YY,EE> function)
static void	Task.errorExit(java.lang.Throwable ex)	Exit the task with a throwable indicating an error condition.
void	Continuation.execute()	the top level entrypoint for the continuation override this method cannot be called directly - use run() instead use Fiber.yield() to yield control cooperatively and return execution to the caller of run()
void	Fiber.Worker.execute()
void	Pausable.Fork.execute()
void	Pausable.Fork1.execute(AA arg1)
TT	Pausable.Spawn.execute()
void	Task.execute()
void	Task.Fork.execute()
void	Task.Invoke.execute()
void	Task.Spawn.execute()
void	TaskGroup.execute()
static void	Task.exit(java.lang.Object aExitValue)	Analogous to System.exit, except an Object can be used as the exit value
void	MailboxSPSC.fill(T[] msg)	Pausable fill Pause the caller until at least one message is available.
T	Cell.get()
T	Cell.get(long timeoutMillis)
T	Mailbox.get()
T	Mailbox.get(long timeoutMillis)
T	MailboxMPSC.get()
T	MailboxMPSC.get(long timeoutMillis)
T	MailboxSPSC.get()
T	MailboxSPSC.get(long timeoutMillis)
static Task	Task.getCurrentTask()	This is a placeholder that doesn't do anything useful.
java.lang.String	ServletHandler.Iface.handle(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp)
static java.lang.Object	Task.invoke(java.lang.reflect.Method method, java.lang.Object obj, java.lang.Object... args)	Invoke a pausable method via reflection.
ExitMsg<TT>	Task.join()
ExitMsg	TaskGroup.join()
static void	Fiber.pause()
static void	Task.pause(PauseReason pauseReason)	Ask the current task to pause with a reason object, that is responsible for resuming the task when the reason (for pausing) is not valid any more.
void	ReentrantLock.preLock()
void	Task.prePin()
void	Cell.put(T msg)
boolean	Cell.put(T msg, int timeoutMillis)
void	Mailbox.put(T msg)	put a non-null message in the mailbox, and pause the calling task until the mailbox has space
boolean	Mailbox.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.
void	MailboxMPSC.put(T msg)	put a non-null message in the mailbox, and pause the calling task until the mailbox has space
boolean	MailboxMPSC.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.
void	MailboxSPSC.put(T msg)	put a non-null message in the mailbox, and pause the calling task until the mailbox has space
void	MailboxSPSC.put(T[] buf)	put a non-null messages from buffer in the mailbox, and pause the calling task until all the messages put in the mailbox
boolean	MailboxSPSC.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.
void	Task.resumeOnScheduler(Scheduler s)
static int	Mailbox.select(Mailbox... mboxes)	Takes an array of mailboxes and returns the index of the first mailbox that has a message.
static void	Task.sleep(long millis)
void	MailboxSPSC.subscribe(boolean avail, Task t, boolean set)
void	Mailbox.untilHasMessage()	Block caller until at least one message is available.
void	Mailbox.untilHasMessages(int num)	Block caller until num messages are available.
static void	Fiber.yield()	yield cooperatively to the next task waiting to use the thread
void	Generator.yield(T val)
static void	Task.yield()	Yield cooperatively to the next task waiting to use the thread.

Uses of Pausable in kilim.concurrent

Methods in kilim.concurrent that throw Pausable

Modifier and Type	Method	Description
void	SPSCQueue.putMailbox(T[] buf, MailboxSPSC mb)

Uses of Pausable in kilim.examples

Methods in kilim.examples that throw Pausable

Modifier and Type	Method	Description
static void	Userdata.Eats5.buff(int kfood)
boolean	HttpFileServer.check(HttpResponse resp, java.io.File file)
void	TimerBlast.Tick.dive(int depth)
void	TimerBlast2.Tick.dive(int depth)
void	TimerBlast2.Tock.dive(int depth)
static void	Userdata.eater(Userdata.Eats4 eat, int kfood)
private void	Spawn.exampleUsage()
void	Chain.execute()
void	Ex.execute()	The entry point.
void	Fib.execute()
void	Group.GroupTask.execute()
void	HttpFileServer.execute()
void	PerfTest.execute()
void	PerfTest.Producer1.execute()
void	Ping.Server.execute()
void	Post.execute()
void	Pre.execute()
void	Pure.PureDemo.execute()
void	Pure.PureMega.execute()
void	Pure.TaskDemo.execute()
void	Reflect.execute()
void	SimpleHttpServer.SimpleHttpSession.execute()
void	SimpleTask.execute()	The entry point.
void	SimpleTask2.execute()	The entry point.
void	TimedTask.execute()
void	TimerBlast.execute()
void	TimerBlast.Tick.execute()
void	TimerBlast2.Tick.execute()
void	TimerBlast2.Tock.execute()
void	Userdata.execute()
void	Xorshift.X1.execute()
void	Xorshift.X2.execute()
private void	Ex.foo(int i)
void	Userdata.Eats1.insert1(int kfood)
void	Userdata.Eats1Impl.insert1(int kfood)
void	Userdata.Eats2.insert1(int kfood)
void	Userdata.Eats3.insert1(int kfood)
void	Userdata.Eats4.insert1(int kfood)
void	Userdata.Eats2.insert2(int kfood)
void	HttpFileServer.problem(java.io.File file, HttpResponse resp, byte[] statusCode, java.lang.String msg)
void	HttpFileServer.sendDirectory(HttpResponse resp, java.io.File file, boolean headOnly)
void	HttpFileServer.sendFile(HttpResponse resp, java.io.File file, boolean headOnly)
static int	Reflect.static_test()
int	Reflect.test()
(package private) void	Post.walk(Tree t)
(package private) void	Pre.walk(Tree t)

Uses of Pausable in kilim.http

Methods in kilim.http that throw Pausable

Modifier and Type	Method	Description
java.lang.Object	KilimMvc.Fullable0.accept(HttpRequest req, HttpResponse resp)
void	KilimMvc.Preppable.accept(PP val)
java.lang.Object	KilimMvc.Routeable0.accept()
java.lang.Object	KilimMvc.Routeable1.accept(java.lang.String s1)
java.lang.Object	KilimMvc.Routeable2.accept(java.lang.String s1, java.lang.String s2)
java.lang.Object	KilimMvc.Routeable3.accept(java.lang.String s1, java.lang.String s2, java.lang.String s3)
java.lang.Object	KilimMvc.Routeable4.accept(java.lang.String s1, java.lang.String s2, java.lang.String s3, java.lang.String s4)
java.lang.Object	KilimMvc.Routeable5.accept(java.lang.String s1, java.lang.String s2, java.lang.String s3, java.lang.String s4, java.lang.String s5)
java.lang.Object	KilimMvc.Routeablex.accept(java.lang.String[] keys)
boolean	HttpSession.check(HttpResponse resp, java.io.File file, java.lang.String... bases)
void	HttpSession.StringSession.execute()
void	KilimMvc.Session.execute()
void	HttpRequest.fill(EndPoint endpoint, int offset, int size)
void	KilimMvc.KilimHandler.handle(KilimMvc.Session session, HttpRequest req, HttpResponse resp)
void	KilimMvc.Session.handle(HttpRequest req, HttpResponse resp)
void	HttpSession.problem(HttpResponse resp, byte[] statusCode, java.lang.String htmlMsg)	Send an error page to the client.
void	HttpRequest.readAllChunks(EndPoint endpoint)
void	HttpRequest.readBody(EndPoint endpoint)
void	HttpRequest.readFrom(EndPoint endpoint)
void	HttpRequest.readHeader(EndPoint endpoint)
int	HttpRequest.readLine(EndPoint endpoint)
HttpRequest	HttpSession.readRequest(HttpRequest req)	Reads the socket, parses the HTTP headers and the body (including chunks) into the req object.
java.lang.String	HttpSession.StringRouter.route(HttpRequest req)
(package private) java.lang.Object	KilimMvc.route(KilimMvc.Routeable hh, java.lang.String[] keys)
(package private) java.lang.Object	KilimMvc.route(KilimMvc.Router pp, KilimMvc.Session session, KilimMvc.Route r2, KilimMvc.Routeable hh, java.lang.String[] keys, HttpRequest req, HttpResponse resp)
java.lang.Object	KilimMvc.route(KilimMvc.Session session, HttpRequest req, HttpResponse resp)
void	KilimMvc.Session.send(HttpResponse resp, byte[] msg, java.lang.String type)
int	HttpSession.sendFile(HttpRequest req, HttpResponse resp, java.io.File file, java.lang.String contentType)	send a file with content length to the client
void	HttpSession.sendResponse(HttpResponse resp)	Send the response object in its entirety, and mark it for reuse.
void	HttpResponse.writeTo(EndPoint endpoint)

Uses of Pausable in kilim.nio

Methods in kilim.nio that throw Pausable

Modifier and Type	Method	Description
void	NioSelectorScheduler.ListenTask.execute()
void	NioSelectorScheduler.RegistrationTask.execute()
java.nio.ByteBuffer	EndPoint.fill(java.nio.ByteBuffer buf, int atleastN)	Read atleastN bytes more into the buffer if there's space.
java.nio.ByteBuffer	EndPoint.fillMessage(java.nio.ByteBuffer bb, int lengthLength, boolean lengthIncludesItself)	Reads a length-prefixed message in its entirety.
void	EndPoint.pauseUntilAcceptable()
void	EndPoint.pauseUntilReadable()
void	EndPoint.pauseUntilWritable()
void	EndPoint.write(java.nio.ByteBuffer buf)	Write buf.remaining() bytes to dataChannel().
void	EndPoint.write(java.nio.channels.FileChannel fc, long start, long length)	Write a file to the endpoint using FileChannel.transferTo(long, long, java.nio.channels.WritableByteChannel)

Uses of Pausable in kilim.support

Methods in kilim.support that throw Pausable

Modifier and Type	Method	Description
java.lang.String	JettyHandler.Iface.handle(java.lang.String target, org.eclipse.jetty.server.Request br, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp)
java.lang.String	JettyHandler.Java7Handler.handle(java.lang.String arg0, org.eclipse.jetty.server.Request arg1, javax.servlet.http.HttpServletRequest arg2, javax.servlet.http.HttpServletResponse arg3, Fiber arg4)