Examples of com.sun.sgs.kernel.TaskScheduler

com.sun.sgs.kernel.TaskScheduler

This interface is used to run tasks that may take an arbitrarily long time to complete, but are expected to complete eventually. These tasks may be scheduled to run immediately or after some delay, possibly re-executing at regular intervals.

Based on an implementation's policy, a task and its owner, that task may not be accepted for execution. In this case {@code TaskRejectedException}is thrown. To ensure that a task will be accepted methods are provided to get a {@code TaskReservation}. This is especially useful for {@code Service}methods working within a transaction that need to ensure that a task will be accepted before they can commit.

Note that, because the tasks submitted through this interface may run any length of time, there are no guarantees about when a given task will start. If a task is scheduled to run immediately, or at some point in the future, then this means that the scheduler will try to acquire resources to run the task at that point. It may still be some indefinite length of time before the task can actually be run.

    DATA_STORE_CLASS_PROPERTY);
      optimisticWriteLocks = wrappedProps.getBooleanProperty(
    OPTIMISTIC_WRITE_LOCKS, Boolean.FALSE);
      trackStaleObjects = wrappedProps.getBooleanProperty(
    TRACK_STALE_OBJECTS_PROPERTY, Boolean.FALSE);
      TaskScheduler taskScheduler =
    systemRegistry.getComponent(TaskScheduler.class);
      Identity taskOwner = txnProxy.getCurrentOwner();
      scheduler = new DelegatingScheduler(taskScheduler, taskOwner);
            NodeType nodeType = 
                wrappedProps.getEnumProperty(StandardProperties.NODE_TYPE,

    Level.SEVERE, e, "JeEnvironment initialization failed");
      throw e;
  }
  if (stats >= 0) {
      statsTask = new StatsRunnable();
      TaskScheduler taskScheduler =
    systemRegistry.getComponent(TaskScheduler.class);
      statsTaskHandle = taskScheduler.scheduleRecurringTask(
    statsTask, txnProxy.getCurrentOwner(),
    System.currentTimeMillis() + stats, stats);
  }


        logger.log(Level.CONFIG,

    "DataStore directory does not exist: " + directory);
  } catch (DatabaseException e) {
      throw convertException(e, false);
  }
  checkpointTask = new CheckpointRunnable(checkpointSize);
  TaskScheduler taskScheduler =
      systemRegistry.getComponent(TaskScheduler.class);
  checkpointTaskHandle = taskScheduler.scheduleRecurringTask(
      checkpointTask, txnProxy.getCurrentOwner(),
      System.currentTimeMillis() + checkpointInterval,
      checkpointInterval);


        logger.log(Level.CONFIG,

Examples of com.sun.sgs.kernel.TaskScheduler

Related Classes of com.sun.sgs.kernel.TaskScheduler