一.多線程
???? 1.基本概念
???????? 進程:正在運行中的程序,一個進程中至少包含一個線程
???????? 線程:進程的任務,執行任務的一個通道,一個進程中可以包含多個線程
???? 2.多線程執行的特點:
???????? 兩種方式:分時調度/搶占式調度(java屬于搶占)
二.Thread 類(java.lang)
???? 1.概述:使用該類表示多線程對象,只要創建一個Thread對象,就是一個線程對象產生了
???? 2.定義:public class Thread extends Object implements Runnable
???? 3.構造方法:
???????? Thread():無參構造,分配新的 Thread 對象
???????? Thread(String name):使用指定的名稱分配新的 Thread 對象,設置線程名稱
???????? Thread(Runnable target):接收Runnable接口子類對象,實例化Thread對象
???????? Thread(Runnable target, String name):接收Runnable接口子類對象,實例化Thread對象,并設置線程名稱
???? 4.靜態方法:
???????? public static Thread currentThread(){}:返回目前正在執行的線程 [線程名,優先級,]
???????? public static void sleep(long millis) throws InterruptedException{}:使當前線程休眠多少毫秒
???????? public static void yield(){}:將目前執行的線程暫停,允許其它線程執行
????
???? 5.常用方法:
???????? public void run(){}:如果該線程是使用獨立的 Runnable 運行對象構造的，則調用該 Runnable 對象的 run
???????????????????????????? 方法；否則，該方法不執行任何操作并返回。<所以該方法應自覺重寫!!!>
???????? public void start(){}:使該線程開始執行；Java 虛擬機調用該線程的 run 方法
???????? public final String getName(){}:返回線程的名稱
???????? public final int getPriority(){}:返回線程優先級
???????? public final void setName(String name){}:設定線程名稱
???????? public final void setPriority(int newPriority){}:設定線程的優先值
???????? public final ThreadGroup getThreadGroup(){}:Returns the thread group to which this thread belongs.
???????????????????????????????????????????? This method returns null if this thread has died (been stopped).
???? 代碼演示:
???????

1 //多線程基本練習-Thread類 2 class MyThread extends Thread{ 3 //重寫run() 4 @Override 5 public void run(){ 6 for(int i = 0; i < 100; i++){ 7 System.out.println(Thread.currentThread()+"Jack"+i); 8 } 9 } 10 } 11 12 public class ThreadDemo{ 13 public static void main(String[] args){ 14 //創建一個線程 15 MyThread my = new MyThread(); 16 //啟動線程 17 my.start(); 18 19 //主線程執行如下任務 20 for(int i = 0; i<100; i++){ 21 System.out.println(Thread.currentThread()+"肉絲"+i); 22 } 23 24 //返回當前運行的線程名稱 25 String s = my.getName(); 26 System.out.println("當前線程名稱為:"+s);//Thread-0 27 28 //修改線程名稱 29 my.setName("Smith--"); 30 System.out.println("修改后-當前線程名稱為:"+my.getName()); 31 32 //返回線程優先級 33 int i = my.getPriority(); 34 System.out.println("當前線程優先級為:"+i);//5 35 } 36 }
????????
三.Runnable 接口(java.lang)
???? 1.概述:Runnable 接口只有一個方法,run方法,因此實現Runnable接口的類,必須重寫run方法,否則,語法報錯;
???? 2.實現接口的好處:
???????? 由于類只能是單繼承(即只出現一次extends),若使用接口,則實現類可以繼承其他類,不占用繼承的位置;
???????? 可以多實現,可以將編寫線程類和寫任務代碼(run()方法)的工作分離開;
???? 3.定義:
???????? @FunctionalInterface
???????? public interface Runnable
???? 4.方法:
???????? public void run() 使用實現接口 Runnable 的對象創建一個線程時，啟動該線程將導致在獨立執行的線程中調用對象的 run 方法
代碼演示:
???? 1 //通過Runnable接口實現多線程 2 class MyRunnable implements Runnable{ 3 @Override 4 public void run(){ 5 for(int i = 0; i<100; i++){ 6 System.out.println("Smith----------"+i+Thread.currentThread()); 7 } 8 } 9 } 10 11 public class RunnableDemo{ 12 public static void main(String[] args){ 13 MyRunnable my = new MyRunnable(); 14 Thread myThread = new Thread(my,"smith"); 15 myThread.start(); 16 17 //返回當前線程名稱 18 System.out.println("當前線程:"+Thread.currentThread()); 19 20 for(int i = 0;i<100;i++){ 21 System.out.println("格林:==="+i+Thread.currentThread()); 22 } 23 } 24 }

死鎖現象:
????

1 class Zhangsan{ 2 public void say(){ 3 System.out.println("張三對李四說:你給你畫,我給你書"); 4 } 5 public void get(){ 6 System.out.println("張三得到畫了"); 7 } 8 } 9 10 class Lisi{ 11 public void say(){ 12 System.out.println("李四對張三說:你給我書,我就給你畫"); 13 } 14 public void get(){ 15 System.out.println("李四得到書了"); 16 } 17 } 18 //單例-餓漢式 19 public class ThreadDeadLock implements Runnable{ 20 private static Zhangsan zs = new Zhangsan(); 21 private static Lisi ls = new Lisi(); 22 private boolean flag = false; 23 @Override 24 public void run(){ 25 if(flag){ 26 synchronized(zs){ //單例模式,所以實例化對象只有一個,可以作為鎖使用 27 zs.say(); 28 try{ 29 Thread.sleep(500); 30 }catch(InterruptedException e){ 31 e.printStackTrace(); 32 } 33 synchronized(ls){ 34 zs.get(); 35 } 36 } 37 }else{ 38 synchronized(ls){ 39 ls.say(); 40 try{ 41 Thread.sleep(500); 42 }catch(InterruptedException e){ 43 e.printStackTrace(); 44 } 45 synchronized(zs){ 46 ls.get(); 47 } 48 } 49 } 50 } 51 public static void main(String[] args){ 52 ThreadDeadLock t1 = new ThreadDeadLock(); 53 ThreadDeadLock t2 = new ThreadDeadLock(); 54 t1.flag = true; 55 t2.flag = false; 56 Thread thA = new Thread(t1); 57 Thread thB = new Thread(t2); 58 thA.start(); 59 thB.start(); 60 } 61 }

四.線程安全問題
???? 原因:當多個線程使用共享的資源時,容易發生數據安全的問題;
???? 解決方案:
???????? Java 提供了3種解決安全問題的方式;
???????????? 1:同步代碼塊
???????????? 2:同步方法
???????????? 3:Lock 接口
???? 1.同步代碼塊
???????

1 /*使用3個線程,模擬3個窗口,賣100張票; 2 要求每個線程賣出去的票,不能重復且不能是無效票; 3 使用一個變量表示100張票,每個窗口賣出去一張票,就將該變量的值減一,直到0為止; 4 使用同步代碼塊 5 */ 6 class MyRunnable implements Runnable{ 7 int ticket = 100;//總票數,只能new一次該類,因為每創建一次對象就會有100張票 8 @Override 9 public void run(){ 10 String name = Thread.currentThread().getName();//獲取當前線程名 11 while(true){ 12 synchronized(this){ 13 if(ticket<=0){ 14 break; 15 }else{ 16 System.out.println(name+"賣出第"+ticket+"號票"); 17 ticket--; 18 } 19 } 20 } 21 22 } 23 } 24 25 public class SellTicket{ 26 public static void main(String[] args){ 27 //創建任務對象 28 MyRunnable my = new MyRunnable(); 29 //創建線程 30 Thread t1 = new Thread(my,"窗口1"); 31 Thread t2 = new Thread(my,"窗口2"); 32 Thread t3 = new Thread(my,"窗口3"); 33 //開啟線程 34 t1.start(); 35 t2.start(); 36 t3.start(); 37 } 38 }

??? 2.同步方法
????????

1 class MyRunnable implements Runnable{ 2 //定義總票數為成員變量 3 int ticket = 100; 4 String name; 5 @Override 6 public void run(){ 7 name = Thread.currentThread().getName(); 8 //賣票任務 9 while(true){ 10 sell(); 11 if(ticket<=0){ 12 break; 13 } 14 } 15 } 16 //同步方法 17 public synchronized void sell(){ 18 if(ticket > 0){ 19 System.out.println(name+"賣出第"+ticket+"號票"); 20 ticket--; 21 } 22 } 23 } 24 25 public class SellTicket01{ 26 public static void main(String[] args){ 27 //創建任務對象 28 MyRunnable my = new MyRunnable(); 29 //創建多線程 30 Thread t1 = new Thread(my,"窗口1"); 31 Thread t2 = new Thread(my,"窗口2"); 32 Thread t3 = new Thread(my,"窗口3"); 33 //開啟多線程 34 t1.start(); 35 t2.start(); 36 t3.start(); 37 } 38 }

??? 3.Lock 接口
???????

1 import java.util.concurrent.locks.Lock; 2 import java.util.concurrent.locks.ReentrantLock; 3 class MyRunnable implements Runnable{ 4 //定義票數為成員變量 5 int ticket = 100; 6 //創建鎖對象 7 private static final Lock lock = new ReentrantLock(); 8 @Override 9 public void run(){ 10 String name = Thread.currentThread().getName(); 11 while(true){ 12 lock.lock(); 13 try{ 14 if(ticket > 0){ 15 System.out.println(name+"賣出了第"+ticket+"號票"); 16 ticket--; 17 }else{ 18 break; 19 } 20 }finally{ 21 lock.unlock(); 22 } 23 } 24 } 25 } 26 27 28 public class SellTicket02{ 29 public static void main(String[] args){ 30 //創建任務對象 31 MyRunnable my = new MyRunnable(); 32 //創建多線程 33 Thread t1 = new Thread(my,"窗口1"); 34 Thread t2 = new Thread(my,"窗口2"); 35 Thread t3 = new Thread(my,"窗口3"); 36 //開啟多線程 37 t1.start(); 38 t2.start(); 39 t3.start(); 40 41 } 42 }

五.使用匿名內部類實現多線程
????

1 /*編寫程序，創建兩個線程對象，一根線程循環輸出“播放背景音樂”，另一根線程循環輸出 2 “顯示畫面”，要求線程實現Runnable接口，且使用匿名內部類實現*/ 3 public class ThreadDemo003{ 4 public static void main(String[] args){ 5 new Thread(new Runnable(){ 6 @Override 7 public void run(){ 8 for(int i = 0; i < 100; i++){ 9 System.out.println("播放背景音樂"); 10 } 11 } 12 }).start(); 13 14 new Thread(new Runnable(){ 15 @Override 16 public void run(){ 17 for(int i = 0; i <100; i++){ 18 System.out.println("顯示畫面"); 19 } 20 } 21 }).start(); 22 } 23 } 1 /*編寫程序，創建兩個線程對象，一根線程循環輸出“播放背景音樂”，另一根線程循環輸出 2 “顯示畫面”，要求使用Thread類，且使用匿名內部類實現*/ 3 public class ThreadDemo03{ 4 public static void main(String[] args){ 5 new Thread(){ 6 @Override 7 public void run(){ 8 for(int i = 0; i<100; i++){ 9 System.out.println("播放背景音樂"); 10 } 11 } 12 }.start(); 13 14 new Thread(){ 15 @Override 16 public void run(){ 17 for(int i = 0; i<100; i++){ 18 System.out.println("顯示畫面"); 19 } 20 } 21 }.start(); 22 } 23 } 24

六.ThreadGroup 類(java.lang)
???? 簡介:線程組:java允許對一批線程進行管理,使用ThreadGroup表示線程組,所有線程均有指定線程組,如果沒有顯式指定,則為默認線程組.默認情況下,子線程和創建他的父線程
???????? 屬于同一線程組.一旦某線程加入指定線程組內,該線程會一直屬于該組,直至死亡,運行過程中不可改變.
???? 繼承關系:java.lang.Object--java.lang.ThreadGroup
???? 定義:public class ThreadGroup extends Object implements Thread.UncaughtExceptionHandler
???? 構造器:
???????? ThreadGroup(String name): Constructs a new thread group.
???????? ThreadGroup(ThreadGroup parent, String name): Creates a new thread group.
???? 常用方法:
???????? public int activeCount(){}:Returns an estimate of the number of active threads in this thread group and its subgroups
???????? public int activeGroupCount(){}:Returns an estimate of the number of active groups in this thread group and its subgroups.
???????????????????????????????????????? Recursively iterates over all subgroups in this thread group.
???????? public int enumerate(Thread[] list) Throws SecurityException{}:
???????? public int enumerate(Thread[] list,boolean recurse)Throws SecurityException{}:Copies into the specified array every active thread
???????????????????????????????????????????????? in this thread group. If recurse is true, this method recursively enumerates all subgroups of
???????????????????????????????????????????????? this thread group and references to every active thread in these subgroups are also included.
???????????????????????????????????????????????? If the array is too short to hold all the threads, the extra threads are silently ignored.
???????? public final String getName(){}:Returns the name of this thread group.
???????? public final ThreadGroup getParent()Throws SecurityException{}:Returns the parent of this thread group.
???????? public final boolean isDaemon(){}:Tests if this thread group is a daemon thread group
???????? public final void checkAccess() Throws SecurityException{}:Determines if the currently running thread has permission to modify this thread group.
???????? public final void setDaemon(boolean daemon)Throws SecurityException{}:Changes the daemon status of this thread group.???
????
???? 代碼演示:獲取當前系統內運行的所有線程組及線程名
???????

1 import java.util.List; 2 import java.util.ArrayList; 3 public class ThreadListDemo{ 4 public static void main(String[] args){ 5 for(String s : getThreadGroups(getRootThreadGroups())){ 6 System.out.println(s); 7 } 8 } 9 10 //getRootThreadGroups() 11 public static ThreadGroup getRootThreadGroups(){ 12 //get current threadgroup 13 ThreadGroup rootGroup = Thread.currentThread().getThreadGroup(); 14 while(true){ 15 if(rootGroup.getParent() != null){ 16 rootGroup = rootGroup.getParent(); 17 }else{ 18 break; 19 } 20 21 } 22 return rootGroup; 23 } 24 25 //getThreadGroups()傳入一個線程組,獲取該組內所有子線程組 26 public static List<String> getThreadGroups(ThreadGroup group){ 27 List<String> threadList = getThreads(group);//存子線程組名,調用getThreads方法,返回線程組內所有線程名 28 ThreadGroup[] groups = new ThreadGroup[group.activeGroupCount()];//活動的線程組名 29 int count = group.enumerate(groups,false);//復制子線程組到線程組數據,不遞歸復制 30 for(int i = 0; i< count; i++){ 31 threadList.addAll(getThreads(groups[i])); 32 } 33 return threadList; 34 } 35 36 37 //傳入一個線程組,返回該組內所有線程名 38 public static List<String> getThreads(ThreadGroup group){ 39 List<String> threadList = new ArrayList<>();//存線程名 40 Thread[] list = new Thread[group.activeCount()];//活動線程 41 int count = group.enumerate(list,false);//復制當前進程到list中 42 for(int i = 0; i< count; i++){ 43 threadList.add("名為:"+group.getName()+"的線程組,線程名為:"+list[i].getName()); 44 } 45 return threadList; 46 } 47 48 }

七.Executor 接口(java.io.concurrent)
簡介:線程池:由于線程涉及到與操作系統交互,所以啟動一個新線程的成本比較高,因此,java提供了線程池機制來提高性能,尤其是當程序中需要大量生存期很短暫的線程時,應該考慮
???? 使用線程池.所謂線程池是指在系統啟動時即創建大量空閑的線程,程序將一個Runnable對象或Callable對象傳給線程池,線程池就會啟動一個線程來執行他們的run或call方法,當方法
???? 結束時,線程并不會死亡,而是返回線程池成為空閑狀態,等待執行下一個任務
定義: public interface Executor
方法:public void execute(Runnable command) Throws RejectedExecutionException | NullPointerException {}:Executes the given command at some time in the future
實現類:AbstractExecutorService, ForkJoinPool, ScheduledThreadPoolExecutor, ThreadPoolExecutor
子接口:ExecutorService, ScheduledExecutorService

轉載于:https://www.cnblogs.com/huguangqin/p/7128802.html

總結

以上是生活随笔為你收集整理的多线程-Thread-Runnable的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。