1、線程的基本概念

例子：

分析：

2、線程的創(chuàng)建和啟動(dòng)

第一種線程的創(chuàng)建：

????定義一個(gè)線程類來實(shí)現(xiàn)Runner接口

例子：

package com.zhj.www; import java.lang.Thread; public class TestThread1 {public static void main(String[] args) {Runner1 runner1 = new Runner1();Thread myThread = new Thread(runner1);myThread.start();//這行注釋掉的話，線程就不會(huì)執(zhí)行。for(int i=0;i<100;i++) {System.out.println("Main Thread:-----" + i);}} } class Runner1 implements Runnable{public void run() {for(int i = 0;i<100;i++) {System.out.println("Runner1:" + i);}} }

運(yùn)行結(jié)果：

我們會(huì)發(fā)現(xiàn)，主線程，和子線程是交替執(zhí)行的。

但是呢，要注意：

但是若是直接調(diào)用run方法，是方法調(diào)用，兩者之間天壤之別，只有執(zhí)行完成一個(gè)才會(huì)去執(zhí)行另一個(gè)。

package com.zhj.www; import java.lang.Thread; public class TestThread1 {public static void main(String[] args) {Runner1 runner1 = new Runner1();//Thread myThread = new Thread(runner1);runner1.run();//myThread.start();//這行注釋掉的話，線程就不會(huì)執(zhí)行。for(int i=0;i<100;i++) {System.out.println("Main Thread:-----" + i);}} } class Runner1 implements Runnable{public void run() {for(int i = 0;i<100;i++) {System.out.println("Runner1:" + i);}} }證明如下：

第二種線程的創(chuàng)建：

定義一個(gè)Thread的子類并重寫其run方法。

例子：

package com.zhj.www; import java.lang.Thread; public class TestThread1 {public static void main(String[] args) {MyThread myThread = new MyThread();myThread.start();for(int i=0;i<100;i++) {System.out.println("Main Thread:-----" + i);}} } class MyThread extends Thread{public void run() {for(int i = 0;i<100;i++) {System.out.println("Runner1:" + i);}} }

此時(shí)，已經(jīng)新建一個(gè)MyThread類繼承自Thread類，所以就不用new一個(gè)Thread 的對象出來了，而只需要new一個(gè)MyThread的子對象。然后調(diào)用其start()方法。

執(zhí)行結(jié)果：

我們發(fā)現(xiàn)和第一種創(chuàng)建線程的結(jié)果是一樣的，也是交替執(zhí)行。但是兩個(gè)線程分得到的時(shí)間片并不一定是相同的。

兩個(gè)方式有什么區(qū)別呢？繼承Thread類的方式（第二種方式）比較死，只能從一個(gè)類繼承，第一種方式呢？比較靈活實(shí)現(xiàn)接口，還可以從其他類繼承。只要能實(shí)現(xiàn)接口，就不要從Thread類繼承。

線程狀態(tài)轉(zhuǎn)換：

1、sleep方法：

package com.zhj.www;import java.util.*;public class TestInterrupt {public static void main(String[] args) {MyThread thread = new MyThread();thread.start();try {Thread.sleep(10000);//主線程睡眠}catch (InterruptedException e) {}//thread.interrupt();//睡著的時(shí)候打斷，太粗暴了//為什么不用它呢？thread.flag = false;} }class MyThread extends Thread{boolean flag = true;public void run() {while(flag) {System.out.println("==="+new Date()+"===");try {sleep(1000);} catch (InterruptedException e) {return;}}} }

運(yùn)行結(jié)果：

2、join方法：

栗子：

package com.zhj.www;public class TestJoin {public static void main(String[] args) {MyThread2 t1 = new MyThread2("abcdef");t1.start();try {t1.join();//合共}catch (InterruptedException e) {}for(int i = 1;i<=10;i++) {System.out.println("I am main thread");}} } class MyThread2 extends Thread{public MyThread2(String s) {super(s);}public void run() {for(int i = 0; i<=10;i++) {System.out.println("I am "+ getName()+" (i:)"+i);try {sleep(1000);} catch (InterruptedException e) {return;}}} }

運(yùn)行結(jié)果：

3、yield方法：

package com.zhj.www;import java.util.*;public class TestYield {public static void main(String[] args) {MyThread3 t1 = new MyThread3("t1");MyThread3 t2 = new MyThread3("t2");t1.start();t2.start();} }class MyThread3 extends Thread{MyThread3(String s) {super(s);}public void run() {for (int i = 1; i <= 100; i++) {System.out.println(getName()+": "+i);if(i%10 == 0) {yield();}}} }

運(yùn)行結(jié)果：

t1到10的倍數(shù)切換t2，t2到10的倍數(shù)切換t1；

上例子：

package com.zhj.www;public class TestPriority {public static void main(String[] args) {Thread t1 = new Thread(new T1());Thread t2 = new Thread(new T2());t1.setPriority(Thread.NORM_PRIORITY+3);//t1得到的執(zhí)行時(shí)間長t1.start();t2.start();} } class T1 implements Runnable{public void run() {for(int i =0;i< 100;i++) {System.out.println("T1: "+ i);}} } class T2 implements Runnable{public void run() {for(int i =0;i< 100;i++) {System.out.println("-------T2: "+ i);}} }運(yùn)行一下：

可以發(fā)現(xiàn)：t1比t2運(yùn)行的時(shí)間長。

--------------------------------------------------------------------------------------

--------------------------------------------------------------------------------------

額外的栗子：

--------------------------------------------------------------------------------------

TestThread2.java

package com.zhj.www;public class TestThread2 {public static void main(String[] args) {Runner2 r = new Runner2();Thread t1 = new Thread(r);Thread t2 = new Thread(r);t1.start();t2.start();} }class Runner2 implements Runnable{public void run() {for(int i = 0; i <= 30; i++) {System.out.println("No: "+ i);}} }

運(yùn)行一下：

TestThread3.java

package com.zhj.www;public class TestThread3 {public static void main(String[] args) {Runner3 runner3 = new Runner3();Thread thread = new Thread(runner3);thread.start();} } class Runner3 implements Runnable {public void run() {for(int i = 0; i<30;i++) {if(i%10 == 0 && i != 0) {try {Thread.sleep(2000);} catch (InterruptedException e) {}}System.out.println("No. " + i);}} }

當(dāng)i 是 10的倍數(shù)時(shí)，會(huì)睡眠2s。

運(yùn)行結(jié)果：

TestThread4.java

package com.zhj.www;public class TestThread4 {public static void main(String[] args) {Runner4 r = new Runner4();Thread t = new Thread(r);t.start();for(int i = 0; i< 100000 ; i++) {if(i%10000 == 0 & i>0) {System.out.println("in thread main i =" + i);} }System.out.println("Thread mian is over");r.shutDown();} }class Runner4 implements Runnable{private boolean flag = true;public void run() {int i = 0;while(flag == true) {System.out.println(" " + i++);}}public void shutDown() {flag = false;} }

主要：怎么讓一個(gè)正常執(zhí)行的線程停止。

run方法結(jié)束，線程就結(jié)束。

運(yùn)行結(jié)果：

TestThread5.java（關(guān)于join方法）

package com.zhj.www;public class TestThread5 {public static void main(String[] args) {Runner5 r = new Runner5();Thread thread = new Thread(r);thread.start();try {thread.join();}catch (InterruptedException e) {}for(int i = 0; i<50;i++) {System.out.println("主線程："+ i);}} } class Runner5 implements Runnable{public void run(){for(int i= 0 ;i<50;i++) {System.out.println("SubThread: " + i);}} }運(yùn)行結(jié)果：

TestThread6.java

package com.zhj.www;public class TestThread6 {public static void main(String[] args) {Thread thread = new Runner6();thread.start();for(int i = 0; i<50 ;i++) {System.out.println("MainThread: "+ i);}} }class Runner6 extends Thread{public void run() {System.out.println(Thread.currentThread().isAlive());for(int i = 0;i<50;i++) {System.out.println("SubThread: " + i);}} }

----------------------------------------------------------------------------------------------------------------

----------------------------------------------------------------------------------------------------------------

線程同步

自身是一個(gè)線程類。

分析內(nèi)存：

分析完內(nèi)存，我們運(yùn)行一下：

package com.zhj.www;public class TestSync implements Runnable{Timer timer =new Timer();public static void main(String[] args) {TestSync testSync = new TestSync();Thread t1 = new Thread(testSync);Thread t2 = new Thread(testSync);t1.setName("t1");t2.setName("t2");t1.start();t2.start();}public void run() {timer.add(Thread.currentThread().getName());} }class Timer{private static int num = 0;public void add(String name ) {num++;try {Thread.sleep(1);} catch (InterruptedException e) {}System.out.println(name+",你是第"+num+"個(gè)使用timer的線程");} }

運(yùn)行一下：

結(jié)果為什么是這樣呢？感覺哪里不對。

線程在執(zhí)行這個(gè)方法時(shí)，被另一個(gè)線程打斷了。寫sleep，是為了

放大這個(gè)效果。

怎么解決呢？

在執(zhí)行的時(shí)候，鎖定當(dāng)前對象。一個(gè)執(zhí)行進(jìn)入到鎖住區(qū)域時(shí)，另一個(gè)

線程不可打擾。

如下：

public void add(String name ) {synchronized (this) {num++;try {Thread.sleep(1);} catch (InterruptedException e) {}System.out.println(name+",你是第"+num+"個(gè)使用timer的線程");}}

互斥鎖。

另外簡便的寫法：

public synchronized void add(String name ) {//synchronized (this) {num++;try {Thread.sleep(1);} catch (InterruptedException e) {}System.out.println(name+",你是第"+num+"個(gè)使用timer的線程");//}}

執(zhí)行這個(gè)方法時(shí)，鎖住當(dāng)前對象。

睡著的時(shí)候，依然抱著這把鎖，其他的人如果要執(zhí)行這個(gè)方法必須等他執(zhí)行完這個(gè)方法。

總結(jié)

以上是生活随笔為你收集整理的Java 线程多线程编程1---基础的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。