线程的start方法剖析

缺乏、安全感 2024-03-16 14:39 17阅读 0赞

###  线程的start方法剖析 ###

public synchronized void start() {
        
        if (threadStatus！=0)
        throw new IllegalThreadStateException();
        group.add(this);
        boolean started = false;
        try {
        
            start0();
            started = true;
        } finally {
        
            try {
        
                if (！started){
        
                    group.threadStartFailed(this);
                }
            } catch (Throwable ignore) {
        
            }
        }
    }

<table> 
 <thead> 
  <tr> 
   <th align="left">Thread start方法源码</th> 
   <th align="left">总结</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">public synchronized void start() { </td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">if (threadStatus！=0)</td> 
   <td align="left">·Thread被构造后的NEW状态，事实上threadStatus这个内部属性为<code>0</code>。</td> 
  </tr> 
  <tr> 
   <td align="left">throw new IllegalThreadStateException();</td> 
   <td align="left">·不能<code>两次启动</code>Thread，否则就会出现IllegalThreadStateException异常。<br><br>·一个线程生命周期<code>结束</code>，也就是到了TERMINATED状态，再次调用start方法是不允许的，也就是说TERMINATED状态是没有办法回到RUNNABLE/RUNNING状态的。</td> 
  </tr> 
  <tr> 
   <td align="left">group.add(this);</td> 
   <td align="left">·线程启动后将会被加入到一个ThreadGroup中，后文中我们将详细介绍ThreadGroup。</td> 
  </tr> 
  <tr> 
   <td align="left">boolean started = false;</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">try { </td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">start0();</td> 
   <td align="left">JDK的官方文档：※ Causes this thread to begin execution; the Java Virtual Machine calls the <code>run</code> method of this thread.<br>上面这句话的意思是：在开始执行这个线程时，JVM将会调用该线程的run方法，换言之，run方法是被JNI方法<code>start0()</code>调用的。</td> 
  </tr> 
  <tr> 
   <td align="left">started = true;</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">} finally { </td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">try { </td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">if (！started){ </td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">group.threadStartFailed(this);</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">}</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">} catch (Throwable ignore) { </td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">}</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">}</td> 
   <td align="left"></td> 
  </tr> 
  <tr> 
   <td align="left">}</td> 
   <td align="left"></td> 
  </tr> 
 </tbody> 
</table>

### 执行单元 ###

<table> 
 <thead> 
  <tr> 
   <th align="left">线程的真正的执行逻辑是在run方法中，通常我们会把run方法称为线程的<code>执行单元</code></th> 
  </tr> 
 </thead> 
</table>

### 模板设计模式在Thread中的应用 ###

<table> 
 <thead> 
  <tr> 
   <th align="left">其实Thread的run和<code>start</code>就是一个比较典型的模板设计模式，父类编写<code>算法结构代码</code>，子类<code>实现逻辑细节</code></th> 
  </tr> 
 </thead> 
</table>

public class TemplateMethod {
        
        // 父类编写算法结构代码，
        public final void print(String message) {
        
            System.out.println("######befor-add-logic##########");
            wrapPrint(message);
            System.out.println("######after-add-logic##########");
    
        }
        protected void wrapPrint(String message) {
        
        }
    
        public static void main(String[] args) {
        
    
            // 子类实现逻辑细节
            TemplateMethod t1 = new TemplateMethod(){
        
                @Override
                protected void wrapPrint(String message) {
        
                    System.out.println("*"+message+"*");
                }
            };
            t1.print("Hello Thread");
        }
    }

### 策略模式在Thread中的应用 ###

<table> 
 <thead> 
  <tr> 
   <th align="left">无论是Runnable的run方法，还是Thread类本身的run方法，都是想将线程的<code>控制本身</code>和<code>业务逻辑</code>的运行分离开来，达到职责分明、功能单一的原则，这一点与GoF设计模式中的<code>策略设计模式</code>很相似</th> 
  </tr> 
 </thead> 
</table>

public interface RowHandler<T> {
        
        T handle(ResultSet rs);
    }
    
    public class RecordQuery {
        
        private final Connection connection;
    
        public RecordQuery(Connection connection) {
        
            this.connection = connection;
        }
    
        public <T> T query(RowHandler<T> handler, String sql, Object... params) throws SQLException {
        
            try (PreparedStatement stmt = connection.prepareStatement(sql)) {
        
                int index = 1;
                for (Object param : params) {
        
                    stmt.setObject(index++, param);
                }
                ResultSet resultSet = stmt.executeQuery();
                return handler.handle(resultSet);//①调用RowHandler
            }
        }
    }

<table> 
 <thead> 
  <tr> 
   <th align="left">上面这段代码的好处是可以用query方法应对任何数据库的查询，返回结果的不同只会因为你传入RowHandler的不同而不同，同样RecordQuery只负责数据的获取，而RowHandler则负责数据的加工，职责分明，每个类均功能单一</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">相信通过这个简单的示例就类比Thread和Runnable之间的关系。</td> 
  </tr> 
 </tbody> 
</table>

\-----------------------------------------------------------------------------读书笔记摘自书名：Java高并发编程详解：多线程与架构设计 作者：汪文君  
![在这里插入图片描述][2ea0864b1dd74bd7ad08a0a3bae6fbba.png_pic_center]

[2ea0864b1dd74bd7ad08a0a3bae6fbba.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/7006d659ff9443caa98f9210191d7c0c.png