java多線程入門知識及示例程序

更新時間：2013年12月30日 15:11:02 投稿：zxhpj

java多線程入門知識及示例程序,大家參考使用吧

為什么需要多線程？

模型的簡化，如某些程序是由多個相對任務(wù)的運行：

圖形界面的出現(xiàn)，輸入、輸出的阻塞

多核CPU的更好利用

異步行為的需要

Java多線程的特性：

程序的入口main本身是一個線程

線程是并發(fā)的，無序執(zhí)行的

線程內(nèi)部是順序執(zhí)行的

共享數(shù)據(jù)

Java多線程的風(fēng)險：

安全風(fēng)險：由于線程的操作順序是不確定的，某些在單線程下能運行的程序到多線程下會出現(xiàn)意外的結(jié)果。

性能風(fēng)險：服務(wù)器的吞吐量、響應(yīng)性、資源消耗

Java多線程API：

Java可以通過兩種形式創(chuàng)建線程：一、實現(xiàn)Runnable接口，二、繼承Thread類。

繼承thread創(chuàng)建線程示例代碼

復(fù)制代碼代碼如下:

public class ThreadTest extends Thread { 
 
    public static void main(String[] args) { 
        ThreadTest thread = new ThreadTest(); 
        thread.start(); 
        for (int i=0; i<10; i++) { 
            System.out.println("main:"+i); 
        } 
    } 
 
    @Override 
    public void run() { 
        for (int i=0; i<10; i++) { 
            System.out.println("thread:"+i); 
        } 
    } 
 
} 

實現(xiàn)runnable創(chuàng)建線程代碼

復(fù)制代碼代碼如下:

package com.openrdp.thread.api; 
 
public class RunnableTest implements Runnable { 
 
    public static void main(String[] args) { 
        RunnableTest runnable = new RunnableTest(); 
        Thread thread = new Thread(runnable); 
        thread.start(); 
        for (int i=0; i<10; i++) { 
            System.out.println("main:"+i); 
        } 
    } 
 
    @Override 
    public void run() { 
        for (int i=0; i<10; i++) { 
            System.out.println("thread:"+i); 
        } 
    } 
 
} 

Java線程池技術(shù)

Executors獲取exceuctorservice線程池代碼

復(fù)制代碼代碼如下:

package com.openrdp.thread.api; 
 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
 
public class TreadPoolTest { 
    public static void main(String[] args) { 
        ExecutorService threadPool = Executors.newFixedThreadPool(99); 
        TaskThread thread1 = new TaskThread("t1"); 
        threadPool.execute(thread1); 
        TaskThread thread2 = new TaskThread("t2"); 
        threadPool.execute(thread2); 
         
    } 
     
    static class TaskThread implements Runnable { 
        String param; 
        public TaskThread(String param) { 
            this.param = param; 
        } 
 
        @Override 
        public void run() { 
             
        } 
    } 
}