Examples of addTask()


Examples of com.alibaba.taobao.worker.ConfigurableWorker.addTask()

                TimeUnit.MILLISECONDS.sleep(50);
                continue;
            }

            PageURLMiningTask task = new PageURLMiningTask(targetURL);
            taskID2TaskMap.putIfAbsent(worker.addTask(task), task);

            TimeUnit.MILLISECONDS.sleep(100);
        }

        worker.stop();
View Full Code Here

Examples of com.art.anette.client.controller.TaskComboBoxModel.addTask()

        TaskSelection ts = new TaskSelection(logic);
        Task t = ts.getTask();
        if (t != null) {
            ControlContainer cc = controls.get(0);
            TaskComboBoxModel tcm = (TaskComboBoxModel) cc.cbTasks.getModel();
            tcm.addTask(t);
            for (ControlContainer ccc : controls) {
                ccc.cbTasks.setSelectedIndex(cc.cbTasks.getItemCount() - 1);
            }
        }
    }
View Full Code Here

Examples of com.centraview.projects.task.TaskLocal.addTask()

    try {
      InitialContext ic = CVUtility.getInitialContext();
      TaskLocalHome home = (TaskLocalHome)ic.lookup("local/Task");
      TaskLocal remote = (TaskLocal)home.create();
      remote.setDataSource(this.dataSource);
      id = remote.addTask(userId, tvo);
    } catch (Exception e) {
      System.out.println("[Exception][ProjectFacadeEJB.addProjectTask] Exception Thrown: " + e);
      e.printStackTrace();
    }
    return (id);
View Full Code Here

Examples of com.github.overengineer.scope.testutil.thread.TaskThread.addTask()

            }
        });

        TaskThread contractionThread = BasicTaskThread.spawnInstance();
        CollectionContractionTask collectionContractionTask = new CollectionContractionTask(manager);
        contractionThread.addTask(collectionContractionTask);

        TaskThread expansionThread = BasicTaskThread.spawnInstance();
        expansionThread.addTask(new CollectionExpansionTask(manager, collectionContractionTask));

        Thread.sleep(8000L);
View Full Code Here

Examples of com.google.code.rees.scope.testutil.thread.TaskThread.addTask()

      manager.setContextFactory(new DefaultConversationContextFactory());
      manager.setMaxInstances(4);
     
      TaskThread contractionThread = BasicTaskThread.spawnInstance();
      CollectionContractionTask collectionContractionTask = new CollectionContractionTask(manager);
      contractionThread.addTask(collectionContractionTask);
     
      TaskThread expansionThread = BasicTaskThread.spawnInstance();
      expansionThread.addTask(new CollectionExpansionTask(manager, collectionContractionTask));
     
      Thread.sleep(8000L);
View Full Code Here

Examples of com.google.code.rees.scope.util.thread.TaskThread.addTask()

      manager.setContextFactory(new DefaultConversationContextFactory());
      manager.setMaxInstances(4);
     
      TaskThread contractionThread = BasicTaskThread.spawnInstance();
      CollectionContractionTask collectionContractionTask = new CollectionContractionTask(manager);
      contractionThread.addTask(collectionContractionTask);
     
      TaskThread expansionThread = BasicTaskThread.spawnInstance();
      expansionThread.addTask(new CollectionExpansionTask(manager, collectionContractionTask));
     
      Thread.sleep(8000L);
View Full Code Here

Examples of com.puppetlabs.geppetto.validation.runner.RakefileInfo.Rakefile.addTask()

      if(taskInfo == null)
        return result;

      for(Entry<String, String> entry : taskInfo.entrySet())
        result.addTask(new Raketask(entry.getKey(), entry.getValue()));
      return result;
    }
    catch(IOException e) {
      // simply do not return any information - validation should have dealt with errors
      // System.err.println("IOException while processing Rakefile: " + e.getMessage());
View Full Code Here

Examples of com.sun.jsft.tasks.TaskManager.addTask()

        type = task.substring(idx + 1);
        task = task.substring(0, idx);
      }

    // Register the Task...
    tm.addTask(task, type, new DeferredFragmentTaskListener(comp));

    // Count the tasks we depend on...
    taskCount++;
      }
View Full Code Here

Examples of com.sun.sgs.kernel.TaskQueue.addTask()

            TaskQueue queue = taskQueues.get(queueOwner);
            if (queue==null) {
                queue = transactionScheduler.createTaskQueue();
                taskQueues.put(queueOwner, queue);
            }
            queue.addTask(task, identity);
        }
    }

    public void deleteTransactionQueue(Object queueOwner) {
        synchronized(taskQueues) {
View Full Code Here

Examples of com.sun.sgs.kernel.schedule.SchedulerQueue.addTask()

     * Task addition tests.
     */

    @Test public void addTask() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(testTask);
    }

    @Test public void addTaskDelayed() throws Exception {
        SchedulerQueue queue = getQueueInstance();
        queue.addTask(new ScheduledTaskImpl(testTask, 100));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.