背景:
以前想用Semaphore来处理并发访问资源的问题,后来把方案拿给前辈们看的时候,他们说这样也行,但是最好用Task处理,比较简单。所以,顺便学习了下Task.
使用task类创建并执行简单任务
等待任务的完成并获取返回值
使用Co...
分类:
编程语言 时间:
2015-01-25 13:52:05
阅读次数:
728
spark的Executor是执行task的容器。和java的executor概念类似。===================start executor runs task============================->CoarseGrainedExecutorBackend::rec...
分类:
其他好文 时间:
2015-01-25 06:27:23
阅读次数:
213
spring提供了定时任务功能,不需要第三方jar包支持,spring足以。代码:[java] view plaincopypackagecom.inth.product.web.task;importjava.util.Date;importorg.springframework.beans.fa...
分类:
编程语言 时间:
2015-01-25 01:23:27
阅读次数:
399
调度算法的最基本工作之一,就是比较两个可执行的task的优先级。spark提供的FIFO和FAIR的优先级比较在SchedulingAlgorithm这个接口体现。FIFO:--计算优先级的差。注意,在程序中,大部分时候是优先级的数字越小,它优先级越高--如果优先级相同,那么stage编号越靠前,优...
分类:
编程语言 时间:
2015-01-25 01:21:47
阅读次数:
233
任务调度器的接口类。应用程序可以定制自己的调度器来执行。当前spark只实现了一个任务调度器TaskSchedulerImpl===================task scheduler begin====================->TaskSchedulerImpl::submitT...
分类:
其他好文 时间:
2015-01-25 01:18:22
阅读次数:
285
Stage 是一组独立的任务,他们在一个job中执行相同的功能(function),功能的划分是以shuffle为边界的。DAG调度器以拓扑顺序执行同一个Stage中的task。/** * A stage is a set of independent tasks all computing the...
分类:
其他好文 时间:
2015-01-25 01:16:36
阅读次数:
197
//
// main.m
// OC04-task-05
//
// Created by keyzhang on 15-1-24.
// Copyright (c) 2015年 keyzhang. All rights reserved.
//
#import
int main(int argc, const char * argv[]) {
@autoreleasepoo...
分类:
其他好文 时间:
2015-01-24 22:52:43
阅读次数:
120
//
// main.m
// OC04-task-08
//
// Created by keyzhang on 15-1-24.
// Copyright (c) 2015年 keyzhang. All rights reserved.
//
#import
#import "Person.h"
int main(int argc, const char * argv[]) {
...
分类:
编程语言 时间:
2015-01-24 22:49:35
阅读次数:
181
将一个plugin运用到build file中时,会自动创建一系列的构建任务(build task)去运行。Java plugin和Android Plugin也都会如此。
我们对于任务的约定有以下四个:
assemble任务,汇集所有项目输出
...
分类:
其他好文 时间:
2015-01-24 17:09:35
阅读次数:
190
1 2 3 ## framework task result 框架任务部署结果 4 5 6 7 deploy 8 ...
分类:
其他好文 时间:
2015-01-24 15:50:12
阅读次数:
180