Examples of task()

Examples of erjang.EInternalPID.task()

91
92
93
94
95
96
97
98
99
100
101
    }

    // TODO: what if port or pid args are already dead?
   
    iport.set_owner(ipid);
    ipid.task().link_to(iport);
   
    return ERT.TRUE;
   
  }
 
View Full Code Here

Examples of erjang.EInternalPort.task()

283
284
285
286
287
288
289
290
291
292
293
      throw ERT.badarg(node_arg, cid_arg, type_arg);
    }

    EPeer n = EPeer.get_or_create(node, creation, port, flags.value, version.value);
   
    EDriverTask task = port.task();
    if (task != null) {
      task.node(n);

      /*TODO:
    send_nodes_mon_msgs(BIF_P,
View Full Code Here

Examples of groovyx.gpars.group.DefaultPGroup.task()

40
41
42
43
44
45
46
47
48
49
50
        // variable can be assigned once only, read allowed multiple times
        final DataflowVariable<Integer> a = new DataflowVariable<Integer>();

        // group.task will use thread from pool and uses it to execute value bind
        group.task(new Runnable() {
            public void run() {
                // first thread binding value succeeds, other attempts would fail with IllegalStateException
                logMessages.add("Value bound");
                a.bind(10);
            }
View Full Code Here

Examples of groovyx.gpars.group.DefaultPGroup.task()

49
50
51
52
53
54
55
56
57
58
59
                a.bind(10);
            }
        });

        // group.task will use thread from pool and uses it to execute call method
        final Promise<?> result = group.task(new Callable() {
            public Object call() throws Exception {
                // getVal will wait for the value to be assigned
                final int result = a.getVal() + 10;
                logMessages.add("Value calculated");
                return result;
View Full Code Here

Examples of org.geoserver.importer.ImportContext.task()

164
165
166
167
168
169
170
171
172
173
174
        Integer t = obj.integer("task");
        if (t == null) {
            throw new BadRequestException("Request must contain task identifier");
        }

        final ImportTask task = imp.task(t);
        if (task == null) {
            throw new NotFoundException("No such task: " + t + " for import: " + id);
        }

        ResourceInfo resource = task.getLayer().getResource();
View Full Code Here

Examples of org.geoserver.importer.ImportContext.task()

52
53
54
55
56
57
58
59
60
61
62
        ImportTask task = null;

        String t = getAttribute("task");
        if (t != null) {
            int id = Integer.parseInt(t);
            task = context.task(id);
        }
        if (t != null && task == null) {
            throw new RestletException("No such task: " + t + " for import: " + context.getId(),
                    Status.CLIENT_ERROR_NOT_FOUND);
        }
View Full Code Here

Examples of org.geoserver.importer.ImportContext.task()

37
38
39
40
41
42
43
44
45
46
47
        ImportJSONWriter jsonio = new ImportJSONWriter(im, pi, buffer);

        ImportContext c = new ImportContext(0);
        c.addTask(new ImportTask());

        jsonio.transform(transform, 0, c.task(0), true, 1);

        ImportTransform transform2 = new ImportJSONReader(im, buffer.toString()).transform();
        PropertyDescriptor[] pd = BeanUtils.getPropertyDescriptors(transform.getClass());

        for (int i = 0; i < pd.length; i++) {
View Full Code Here

Examples of org.qi4j.library.scheduler.schedule.Schedule.task()

327
328
329
330
331
332
333
334
335
336
337
            Usecase usecase = UsecaseBuilder.newUsecase( "ScheduleRunner" );
            UnitOfWork uow = module.newUnitOfWork( usecase );
            try
            {
                Schedule schedule = uow.get( Schedule.class, this.schedule.scheduleIdentity );
                Task task = schedule.task().get();
                schedule = uow.get( Schedule.class, this.schedule.scheduleIdentity );
                try
                {
                    schedule.taskStarting();
                    task.run();
View Full Code Here

Examples of org.qi4j.library.scheduler.schedule.cron.CronSchedule.task()

70
71
72
73
74
75
76
77
78
79
80
        private CronSchedule newTransientCronSchedule( Task task, String cronExpression, DateTime start )
        {
            ValueBuilder<CronSchedule> builder = module.newValueBuilder( CronSchedule.class );
            CronSchedule prototype = builder.prototype();
            prototype.task().set( task );
            prototype.start().set( start );
            prototype.cronExpression().set( cronExpression );
            CronSchedule schedule = builder.newInstance();
            logger.info( "Schedule {} created: {}", schedule.presentationString(), schedule.identity().get() );
            return schedule;
View Full Code Here

Examples of org.qi4j.library.scheduler.schedule.cron.CronSchedule.task()

83
84
85
86
87
88
89
90
91
92
93
        private CronSchedule newPersistentCronSchedule( Task task, String cronExpression, DateTime start )
        {
            UnitOfWork uow = module.currentUnitOfWork();
            EntityBuilder<CronSchedule> builder = uow.newEntityBuilder( CronSchedule.class );
            CronSchedule builderInstance = builder.instance();
            builderInstance.task().set( task );
            builderInstance.start().set( start );
            builderInstance.cronExpression().set( cronExpression );
            CronSchedule schedule = builder.newInstance();
            logger.info( "Schedule {} created: {}", schedule.presentationString(), schedule.identity().get() );
            return schedule;
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.