Uses of Class
org.jppf.client.balancer.ClientTaskBundle
Packages that use ClientTaskBundle
Package
Description
Support for the new load-balancing of local versus remote execution on the client side.
Support for job queuing in the JPPF client.
Support for connection pool events,
connection status notifications,
job lifecycle events
and job queue events in the JPPF client.
-
Uses of ClientTaskBundle in org.jppf.client
Method parameters in org.jppf.client with type arguments of type ClientTaskBundleModifier and TypeMethodDescriptionvoidAbstractGenericClient.bundleAdded(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidAbstractGenericClient.bundleRemoved(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidJPPFJob.fireJobEvent(JobEvent.Type type, org.jppf.execute.ExecutorChannel<ClientTaskBundle> channel, List<org.jppf.node.protocol.Task<?>> tasks) Notify all listeners of the specified event type.protected voidAbstractGenericClient.fireQueueEvent(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> qEvent, boolean jobAdded) Notify all client queue listeners that a queue event has occurred.Constructor parameters in org.jppf.client with type arguments of type ClientTaskBundleModifierConstructorDescriptionJPPFContextClient(org.jppf.queue.JPPFQueue<ClientJob, ClientJob, ClientTaskBundle> queue) Default initializer. -
Uses of ClientTaskBundle in org.jppf.client.balancer
Methods in org.jppf.client.balancer that return ClientTaskBundleModifier and TypeMethodDescriptionClientJob.copy(int nbTasks) Make a copy of this client job wrapper containing only the first nbTasks tasks it contains.ClientTaskBundle.copy()Make a copy of this bundle.Methods in org.jppf.client.balancer with parameters of type ClientTaskBundleModifier and TypeMethodDescriptionbooleanAbstractChannelWrapperRemote.cancel(ClientTaskBundle bundle) abstract booleanChannelWrapper.cancel(ClientTaskBundle bundle) Cancel the currently executing job, if any.booleanChannelWrapperLocal.cancel(ClientTaskBundle bundle) voidClientJob.jobDispatched(ClientTaskBundle bundle, ChannelWrapper channel) Called when all or part of a job is dispatched to a node.voidClientJob.resultsReceived(ClientTaskBundle bundle, Throwable throwable) Called to notify that throwable eventually raised while receiving the results.voidClientJob.resultsReceived(ClientTaskBundle bundle, List<org.jppf.node.protocol.Task<?>> results) Called to notify that the results of a number of tasks have been received from the server.Future<?>ChannelWrapperLocal.submit(ClientTaskBundle bundle) Future<?>ChannelWrapperRemoteAsync.submit(ClientTaskBundle bundle) voidClientJob.taskCompleted(ClientTaskBundle bundle, Exception exception) Called to notify that the execution of a task has completed. -
Uses of ClientTaskBundle in org.jppf.client.balancer.queue
Methods in org.jppf.client.balancer.queue that return ClientTaskBundleModifier and TypeMethodDescriptionJPPFPriorityQueue.nextBundle(ClientJob job, int nbTasks, org.jppf.execute.ExecutorChannel<ClientTaskBundle> channel) Method parameters in org.jppf.client.balancer.queue with type arguments of type ClientTaskBundleModifier and TypeMethodDescriptionJPPFPriorityQueue.nextBundle(ClientJob job, int nbTasks, org.jppf.execute.ExecutorChannel<ClientTaskBundle> channel) -
Uses of ClientTaskBundle in org.jppf.client.event
Method parameters in org.jppf.client.event with type arguments of type ClientTaskBundleModifier and TypeMethodDescriptionvoidClientQueueEventDispatcher.bundleAdded(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event) voidClientQueueEventDispatcher.bundleRemoved(org.jppf.queue.QueueEvent<ClientJob, ClientJob, ClientTaskBundle> event)