附件中有一个并行计算框架,使用该框架时候,需要在jar包所在目录下创建一个config.xml文件,内容如下,leader的值为集群中master的值,单机情况下运行时leader为本地的值127.0.0.1
<park>
<leader>192.168.0.124:1889</leader>
</park>
下面给出一个使用方法,
自定义供工人累继承自MigrantWorker
public class SimpleWorker extends MigrantWorker{
private double m=0.0,n=0.0;
public SimpleWorker(double m,double n)
{
this.m=m;
this.n=n;
}
protected WareHouse doTask(WareHouse inhouse)
{
System.out.println("向仓库输入");
double pi=0.0;
for(double i=m;i<n;i++)
{
pi+=Math.pow(-1,i+1)/(2*i-1);
}
inhouse.put("pi",4*pi);
System.out.println("输入完毕");
return inhouse;
}
public static void main(String [] args)
{
new SimpleWorker(Integer.parseInt(args[0]),Integer.parseInt(args[1])).waitWorking(args[2],Integer.parseInt(args[3]),args[4]);
}
}
自定义供工头类继承自Contractor
import java.util.*;
public class SimpleCtor extends Contractor{
public static void main(String [] args)
{
long start=new Date().getTime();
WareHouse[] results = doTaskBatch(getWaitingWorkers(args[0]),new WareHouse());//args[0]为工人类型
double pi=0.0;
for(int i=0;i<results.length;i++)
{
pi=pi+Double.parseDouble(results[i].get("pi")+"");
}
System.out.println(pi);
long end=new Date().getTime();
System.out.println((end-start)/1000);
exit();
}
}
运行时先运行java -cp parallel-computing.jar; BeanContext
接着在多个窗口下运行java -cp parallel-computing.jar; SimpleWorker 1 2 工人1IP 工人1端口 工人类型(任意字符串)
然后运行java -cp parallel-computing.jar; SimpleCtor 工人类型即可得到对应公认的计算结果。
该框架是小编仿照fourinone设计思想的简化版本。
分享到:
相关推荐
JAVAOpenMP并行计算框架JAVAOpenMP并行计算框架JAVAOpenMP并行计算框架JAVAOpenMP并行计算框架JAVAOpenMP并行计算框架
在大数据环境下,针对数据型统计分析系统性能劣化明显、不能满足用户使用需求的问题,本文提出了一种轻量级高性能对象化并行计算架构,研制了该架构的对象服务组件、对象管理服务组件和客户端代理组件,并将该架构和...
针对原生的Hadoop云平台处理海洋环境信息可视化效率不高的问题,提出了一种GPU嵌入Hadoop云平台的并行计算框架。该框架以原生Hadoop为基础,GPU并行计算与MapReduce相结合,实现了高效的海洋流场可视化和特征可视化...
淘宝分布式并行计算四合一框架Fourinone 这个是介绍淘宝的分布式应用框架。
采用java8的并行计算,完成1到400亿的数列求和,并行计算完成时间3秒左右,采用普通计算完成时间13秒左右,效果明显
并行计算 陈国良编著 呵呵 大家来下载 是第三版《并行...着力构建并行计算“结构-算法-编程-应用”完整的学科体系与系统的课程框架,在着重讨论并行计算学科基础核心内容的同时,也力图反映本学科的新近成就和发展趋势
Fourinone(中文名字“四不像”)是一个四合一分布式计算框架,在写这个框架之前,我对分布式计算进行了长时间的思考,也看了老外写的其他开源框架,当我们把复杂的hadoop当作一门学科学习时,似乎忘记了我们想解决问题...
每一层分别对应在CMP-CLUSTER混合并行计算 环境概念模型下进行并行处理的某一个特定的目的和步骤。 针对本文提出的并行编程模型中的每一层,本文都研究了相应的简化并行编 程实现的方法、技术和工具,以帮助在混合...
云计算-并行计算框架下人车分类算法研究与优化.pdf
基于Hama并行计算框架的多层级作业调度算法的研究及实现 胡月胜
并行计算框架Spark缺乏有效缓存选择机制,不能自动识别并缓存高重用度数据;缓存替换算法采用LRU,度量方法不够细致,影响任务的执行效率.本文提出一种Spark框架自适应缓存管理策略(Self-Adaptive Cache Management,SACM...
增强的云化并行计算框架系统的设计与实现,涂华轲,邹华,MapReduce是Google提出的一种并行计算框架模型,主要目的是用于大规模数据的并行计算。MapReduce是当今云计算的核心技术之一,它的开源实
分布式并行计算框架PARALL 应用场景:解决实时统计一些复杂的报表,统计的数据量大,而且数据来源多个不同的表结构,最终界面展示超长时间。 解决方案:为了提高效率,用多线程按列去统计,在所有线程完成统计任务...
为了加快SWAT敏感度分析的运行速度,针对SWAT敏感度分析模块的特点,基于MPI提出了一种高效的主—从式并行计算框架,并在此框架的基础上,通过将正演过程并行化,在敏感度分析的主—从并行框架中引入通信子空间的...
parallelextlab 并行计算,包含pLINQ,TASK,PARRALLEL FOR OR FOREACH应用的示例。
基于GPU-Hadoop的并行计算框架研究与实现.pdf
一个通用的、无三方依赖的、跨平台的、收录于awesome-cpp的、基于流图的并行计算框架
云计算-基于改进的MapReduce并行计算框架的网上拍卖系统.pdf