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>
XXPausable. 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>
XXPausable. 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>
XXPausable. apply(XX obj, Pausable.Psumer<XX,EE> func)YYPausable.Pfun. apply(XX obj)voidPausable.Psumer. apply(XX obj)static <XX,EE extends java.lang.Throwable>
XXPausable. 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>
X4Pausable. 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>
ZZPausable. chain(X1 obj, Pausable.Pfun<X1,X2,E1> function1, Pausable.Pfun<X2,ZZ,E2> function2)static <XX,YY,EE extends java.lang.Throwable>
YYPausable. chain(XX obj, Pausable.Pfun<XX,YY,EE> function)static voidTask. errorExit(java.lang.Throwable ex)Exit the task with a throwable indicating an error condition.voidContinuation. 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()voidFiber.Worker. execute()voidPausable.Fork. execute()voidPausable.Fork1. execute(AA arg1)TTPausable.Spawn. execute()voidTask. execute()voidTask.Fork. execute()voidTask.Invoke. execute()voidTask.Spawn. execute()voidTaskGroup. execute()static voidTask. exit(java.lang.Object aExitValue)Analogous to System.exit, except an Object can be used as the exit valuevoidMailboxSPSC. fill(T[] msg)Pausable fill Pause the caller until at least one message is available.TCell. get()TCell. get(long timeoutMillis)TMailbox. get()TMailbox. get(long timeoutMillis)TMailboxMPSC. get()TMailboxMPSC. get(long timeoutMillis)TMailboxSPSC. get()TMailboxSPSC. get(long timeoutMillis)static TaskTask. getCurrentTask()This is a placeholder that doesn't do anything useful.java.lang.StringServletHandler.Iface. handle(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp)static java.lang.ObjectTask. invoke(java.lang.reflect.Method method, java.lang.Object obj, java.lang.Object... args)Invoke a pausable method via reflection.ExitMsg<TT>Task. join()ExitMsgTaskGroup. join()static voidFiber. pause()static voidTask. 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.voidReentrantLock. preLock()voidTask. prePin()voidCell. put(T msg)booleanCell. put(T msg, int timeoutMillis)voidMailbox. put(T msg)put a non-null message in the mailbox, and pause the calling task until the mailbox has spacebooleanMailbox. 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.voidMailboxMPSC. put(T msg)put a non-null message in the mailbox, and pause the calling task until the mailbox has spacebooleanMailboxMPSC. 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.voidMailboxSPSC. put(T msg)put a non-null message in the mailbox, and pause the calling task until the mailbox has spacevoidMailboxSPSC. 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 mailboxbooleanMailboxSPSC. 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.voidTask. resumeOnScheduler(Scheduler s)static intMailbox. select(Mailbox... mboxes)Takes an array of mailboxes and returns the index of the first mailbox that has a message.static voidTask. sleep(long millis)voidMailboxSPSC. subscribe(boolean avail, Task t, boolean set)voidMailbox. untilHasMessage()Block caller until at least one message is available.voidMailbox. untilHasMessages(int num)Block caller untilnummessages are available.static voidFiber. yield()yield cooperatively to the next task waiting to use the threadvoidGenerator. yield(T val)static voidTask. 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 voidSPSCQueue. putMailbox(T[] buf, MailboxSPSC mb) -
Uses of Pausable in kilim.examples
Methods in kilim.examples that throw Pausable Modifier and Type Method Description static voidUserdata.Eats5. buff(int kfood)booleanHttpFileServer. check(HttpResponse resp, java.io.File file)voidTimerBlast.Tick. dive(int depth)voidTimerBlast2.Tick. dive(int depth)voidTimerBlast2.Tock. dive(int depth)static voidUserdata. eater(Userdata.Eats4 eat, int kfood)private voidSpawn. exampleUsage()voidChain. execute()voidEx. execute()The entry point.voidFib. execute()voidGroup.GroupTask. execute()voidHttpFileServer. execute()voidPerfTest. execute()voidPerfTest.Producer1. execute()voidPing.Server. execute()voidPost. execute()voidPre. execute()voidPure.PureDemo. execute()voidPure.PureMega. execute()voidPure.TaskDemo. execute()voidReflect. execute()voidSimpleHttpServer.SimpleHttpSession. execute()voidSimpleTask. execute()The entry point.voidSimpleTask2. execute()The entry point.voidTimedTask. execute()voidTimerBlast. execute()voidTimerBlast.Tick. execute()voidTimerBlast2.Tick. execute()voidTimerBlast2.Tock. execute()voidUserdata. execute()voidXorshift.X1. execute()voidXorshift.X2. execute()private voidEx. foo(int i)voidUserdata.Eats1. insert1(int kfood)voidUserdata.Eats1Impl. insert1(int kfood)voidUserdata.Eats2. insert1(int kfood)voidUserdata.Eats3. insert1(int kfood)voidUserdata.Eats4. insert1(int kfood)voidUserdata.Eats2. insert2(int kfood)voidHttpFileServer. problem(java.io.File file, HttpResponse resp, byte[] statusCode, java.lang.String msg)voidHttpFileServer. sendDirectory(HttpResponse resp, java.io.File file, boolean headOnly)voidHttpFileServer. sendFile(HttpResponse resp, java.io.File file, boolean headOnly)static intReflect. static_test()intReflect. test()(package private) voidPost. walk(Tree t)(package private) voidPre. walk(Tree t) -
Uses of Pausable in kilim.http
Methods in kilim.http that throw Pausable Modifier and Type Method Description java.lang.ObjectKilimMvc.Fullable0. accept(HttpRequest req, HttpResponse resp)voidKilimMvc.Preppable. accept(PP val)java.lang.ObjectKilimMvc.Routeable0. accept()java.lang.ObjectKilimMvc.Routeable1. accept(java.lang.String s1)java.lang.ObjectKilimMvc.Routeable2. accept(java.lang.String s1, java.lang.String s2)java.lang.ObjectKilimMvc.Routeable3. accept(java.lang.String s1, java.lang.String s2, java.lang.String s3)java.lang.ObjectKilimMvc.Routeable4. accept(java.lang.String s1, java.lang.String s2, java.lang.String s3, java.lang.String s4)java.lang.ObjectKilimMvc.Routeable5. accept(java.lang.String s1, java.lang.String s2, java.lang.String s3, java.lang.String s4, java.lang.String s5)java.lang.ObjectKilimMvc.Routeablex. accept(java.lang.String[] keys)booleanHttpSession. check(HttpResponse resp, java.io.File file, java.lang.String... bases)voidHttpSession.StringSession. execute()voidKilimMvc.Session. execute()voidHttpRequest. fill(EndPoint endpoint, int offset, int size)voidKilimMvc.KilimHandler. handle(KilimMvc.Session session, HttpRequest req, HttpResponse resp)voidKilimMvc.Session. handle(HttpRequest req, HttpResponse resp)voidHttpSession. problem(HttpResponse resp, byte[] statusCode, java.lang.String htmlMsg)Send an error page to the client.voidHttpRequest. readAllChunks(EndPoint endpoint)voidHttpRequest. readBody(EndPoint endpoint)voidHttpRequest. readFrom(EndPoint endpoint)voidHttpRequest. readHeader(EndPoint endpoint)intHttpRequest. readLine(EndPoint endpoint)HttpRequestHttpSession. readRequest(HttpRequest req)Reads the socket, parses the HTTP headers and the body (including chunks) into the req object.java.lang.StringHttpSession.StringRouter. route(HttpRequest req)(package private) java.lang.ObjectKilimMvc. route(KilimMvc.Routeable hh, java.lang.String[] keys)(package private) java.lang.ObjectKilimMvc. route(KilimMvc.Router pp, KilimMvc.Session session, KilimMvc.Route r2, KilimMvc.Routeable hh, java.lang.String[] keys, HttpRequest req, HttpResponse resp)java.lang.ObjectKilimMvc. route(KilimMvc.Session session, HttpRequest req, HttpResponse resp)voidKilimMvc.Session. send(HttpResponse resp, byte[] msg, java.lang.String type)intHttpSession. sendFile(HttpRequest req, HttpResponse resp, java.io.File file, java.lang.String contentType)send a file with content length to the clientvoidHttpSession. sendResponse(HttpResponse resp)Send the response object in its entirety, and mark it for reuse.voidHttpResponse. writeTo(EndPoint endpoint) -
Uses of Pausable in kilim.nio
Methods in kilim.nio that throw Pausable Modifier and Type Method Description voidNioSelectorScheduler.ListenTask. execute()voidNioSelectorScheduler.RegistrationTask. execute()java.nio.ByteBufferEndPoint. fill(java.nio.ByteBuffer buf, int atleastN)ReadatleastNbytes more into the buffer if there's space.java.nio.ByteBufferEndPoint. fillMessage(java.nio.ByteBuffer bb, int lengthLength, boolean lengthIncludesItself)Reads a length-prefixed message in its entirety.voidEndPoint. pauseUntilAcceptable()voidEndPoint. pauseUntilReadable()voidEndPoint. pauseUntilWritable()voidEndPoint. write(java.nio.ByteBuffer buf)Write buf.remaining() bytes to dataChannel().voidEndPoint. write(java.nio.channels.FileChannel fc, long start, long length)Write a file to the endpoint usingFileChannel.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.StringJettyHandler.Iface. handle(java.lang.String target, org.eclipse.jetty.server.Request br, javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse resp)java.lang.StringJettyHandler.Java7Handler. handle(java.lang.String arg0, org.eclipse.jetty.server.Request arg1, javax.servlet.http.HttpServletRequest arg2, javax.servlet.http.HttpServletResponse arg3, Fiber arg4)
-