Package org.jppf.server.node

Class JobWriter

java.lang.Object
org.jppf.utils.concurrent.ThreadSynchronization
org.jppf.server.node.JobWriter
All Implemented Interfaces:
Runnable
public class JobWriter extends org.jppf.utils.concurrent.ThreadSynchronization implements Runnable
Get job results from a queue and send them back to the driver.

  • Field Summary

    Fields inherited from class org.jppf.utils.concurrent.ThreadSynchronization

    stopped

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    putJob(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> taskList)
    Put the next job results in the send queue.
    void
    run()
     

    Methods inherited from class org.jppf.utils.concurrent.ThreadSynchronization

    goToSleep, goToSleep, goToSleep, isStopped, setStopped, wakeUp

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable

    • putJob

      public void putJob(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> taskList) throws Exception
      Put the next job results in the send queue.
      Parameters:
      bundle - the bundle that contains the tasks and header information.
      taskList - the tasks results.
      Throws:
      Exception - if any error occurs.