JAVA线程池管理及分布式HADOOP调度框架搭建

359025439

　　平时的开发中线程是个少不了的东西，比如tomcat里的servlet就是线程，没有线程我们如何提供多用户访问呢？不过很多刚开始接触线程的开发攻城师却在这个上面吃了不少苦头。怎么做一套简便的线程开发模式框架让大家从单线程开发快速转入多线程开发，这确实是个比较难搞的工程。
　　那具体什么是线程呢？首先看看进程是什么，进程就是系统中执行的一个程序，这个程序可以使用内存、处理器、文件系统等相关资源。例如 QQ软件、eclipse、tomcat等就是一个exe程序，运行启动起来就是一个进程。为什么需要多线程？如果每个进程都是单独处理一件事情不能多个任务同时处理，比如我们打开qq只能和一个人聊天，我们用eclipse开发代码的时候不能编译代码，我们请求tomcat服务时只能服务一个用户请求，那我想我们还在原始社会。多线程的目的就是让一个进程能够同时处理多件事情或者请求。比如现在我们使用的QQ软件可以同时和多个人聊天，我们用eclipse开发代码时还可以编译代码，tomcat可以同时服务多个用户请求。
　　线程这么多好处，怎么把单进程程序变成多线程程序呢？不同的语言有不同的实现，这里说下java语言的实现多线程的两种方式：扩展java.lang.Thread类、实现java.lang.Runnable接口。
　　先看个例子，假设有100个数据需要分发并且计算。看下单线程的处理速度：
1　　2
　　3
　　4
　　5
　　6
　　7
　　8
　　9
　　10
　　11
　　12
　　13
　　14
　　15
　　16
　　17
　　18
　　19
　　20
　　21
　　22
　　23
　　24
　　25
　　26
packagethread;　　importjava.util.Vector;
　　publicclass OneMain {
　　publicstaticvoid main(String[] args)throwsInterruptedException{
　　Vector list =new Vector(100);
　　for(int i =0; i 0){
　　int val = list.remove(0);
　　Thread. sleep(100);//模拟处理
　　System. out.println(val);
　　}
　　long end =System.currentTimeMillis();
　　System. out.println("消耗 "+(end - start)+" ms");
　　}
　　// 消耗 10063 ms
　　}
　　再看一下多线程的处理速度，采用了10个线程分别处理：
1　　2
　　3
　　4
　　5
　　6
　　7
　　8
　　9
　　10
　　11
　　12
　　13
　　14
　　15
　　16
　　17
　　18
　　19
　　20
　　21
　　22
　　23
　　24
　　25
　　26
　　27
　　28
　　29
　　30
　　31
　　32
　　33
　　34
　　35
　　36
　　37
　　38
　　39
　　40
　　41
　　42
　　43
　　44
　　45
　　46
　　47
　　48
packagethread;　　importjava.util.Vector;
　　importjava.util.concurrent.CountDownLatch;
　　publicclass MultiThread extendsThread{
　　static Vector list =new Vector(100);
　　static CountDownLatch count =new CountDownLatch(10);
　　publicvoid run(){
　　while(list.size()>0){
　　try{
　　int val = list.remove(0);
　　System.out.println(val);
　　Thread.sleep(100);//模拟处理
　　}catch(Exception e){
　　// 可能数组越界，这个地方只是为了说明问题，忽略错误
　　}
　　}
　　count.countDown();// 删除成功减一
　　}
　　publicstaticvoid main(String[] args)throwsInterruptedException{
　　for(int i =0; i