Hadoop源码学习笔记(3) ——初览DataNode及学习线程

lbdbzj110

　　Hadoop源码学习笔记(3)
　　 ——初览DataNode及学习线程
　　进入了main函数，我们走出了第一步，接下来看看再怎么走：

• 
  public class DataNode extends Configured implements InterDatanodeProtocol,
  
• 
        ClientDatanodeProtocol, FSConstants, Runnable {
  
• 
  
• 
     public static DataNode createDataNode(String args[], Configuration conf)
  
• 
           throws IOException {
  
• 
        DataNode dn = instantiateDataNode(args, conf);
  
• 
        runDatanodeDaemon(dn);
  
• 
        return dn;
  
• 
     }
  
• 
  
• 
     public static void runDatanodeDaemon(DataNode dn) throws IOException {
  
• 
           dn.dataNodeThread = new Thread(dn, dnThreadName);
  
• 
           dn.dataNodeThread.setDaemon(true);
  
• 
           dn.dataNodeThread.start();
  
• 
        }
  
• 
     }
  
• 
  
• 
     public static DataNode instantiateDataNode(String args[], Configuration conf)
  
• 
           throws IOException {
  
• 
        return makeInstance(dataDirs, conf);
  
• 
     }
  
• 
  
• 
     public static DataNode makeInstance(String[] dataDirs, Configuration conf) {
  
• 
        return new DataNode(conf, dirs);
  
• 
     }
  
• 
  
• 
     DataNode(Configuration conf, AbstractList dataDirs)
  
• 
           throws IOException {
  
• 
        startDataNode(conf, dataDirs);
  
• 
     }
  
• 
  vid join(){
  
• 
  dataNodeThread.join();
  
• 
  }
  
• 
  
• 
     void startDataNode(Configuration conf, AbstractList dataDirs)
  
• 
           throws IOException {
  
• 
     }
  
• 
  
• 
     public static void main(String args[]) {
  
• 
        DataNode datanode = createDataNode(args, null);
  
• 
        datanode.join();
  
• 
     }
  
• 
  }
  

　　从上面的程序可以看到，程序从main函数中运行，然后一层创建了DataNode对象，然后在runDatanodeDaemon函数创建了一个线程，然后程序调用了线程就停留在哪里了。
　　换个写法，可能看起来更清晰点了：

• 
  public static void main(String args[]) {
  
• 
     DataNode datanode = new DataNode();
  
• 
     Thread dataNodeThread = new Thread(dn, dnThreadName);
  
• 
     dataNodeThread.setDaemon(true);
  
• 
     dataNodeThread.start();
  
• 
     dataNodeThread.join();
  
• 
  }
  

　　这样代码清晰了，换句话说，整个DataNode目前看来，就是一个大线程在跑。
　　整个来讲，线程，还是比较容易理解，整个类继承于Runnable接口，然后实现Run函数。 能过Thread类创建时传入对象实现，在Start后，线程就会运行，执行Run函数内的内容。
　　但这代码中有几行有点疑惑:

• 
  SetDaemon(true):这个函数的意义，并非是简单的字面意义了(Daemon:守护)，一般情况下，当一个线程还没运行完，主程序是卡住的，但设置为daemon为true时，当主程序结束，则线程也就自动结束。
  
• 
  Join():这个函数就是等待线程结束后再往下走。就相当于我们常在主序中写的while(true){}一样。
  

　　
　　创建线程，除了这种继承Runnable接口之外，还可以直接继承Thread类，然后直接调用对象的Start函数。但这样的话不太方便了，因为一个类只能继承一个类，但可继承多个接口，所以用接口更加灵活。
　　
　　针对线程的这两个特性，我们可以写个简单的示例来试验一下：

• 
  import java.io.IOException;
  
• 
  
• 
  public class ThreadTest extends Thread {
  
• 
  
• 
     public class FirstThread extends Thread{
  
• 
  
• 
        @Override
  
• 
        public void run(){
  
• 
  
• 
        }
  
• 
     }
  
• 
  
• 
     public class SecondThread implements Runnable{
  
• 
  
• 
        @Override
  
• 
        public void run() {
  
• 
  
• 
        }
  
• 
     }
  
• 
  
• 
     public void run(){
  
• 
           for(int i = 1; i