快捷導(dǎo)航

Java多線程編程綜合案例詳解

更新時間：2022年07月26日 14:05:08 作者：樣子的木偶

這篇文章將通過三個案例帶大家了解一下Java中的多線程編程，文中的示例代碼介紹詳細(xì)，對我們的學(xué)習(xí)或工作有一定的價值，感興趣的小伙伴可以了解一下

Java多線程綜合案例

數(shù)字加減

設(shè)計(jì)4個線程對象，兩個線程執(zhí)行減操作，兩個線程執(zhí)行加操作

public class ThreadDemo{
    public static void main(String[] args) throws Exception {
        Resource res=new Resource();
        AddThread at=new AddThread(res);
        SubThread st=new SubThread(res);
        new Thread(at,"加法線程A:").start();
        new Thread(at,"加法線程B:").start();
        new Thread(st,"減法線程X:").start();
        new Thread(st,"減法線程Y:").start();
        
        
        
    }
}
class AddThread implements Runnable{//加法操作
    private Resource resource;
    public AddThread(Resource resource) {
        this.resource=resource;
    }
    @Override
    public void run() {
        // TODO Auto-generated method stub
        for(int x=0;x<50;x++) {
            try {
                this.resource.add();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
}
class SubThread implements Runnable{//減法操作
    private Resource resource;
    public SubThread(Resource resource) {
        this.resource=resource;
    }
    @Override
    public void run() {
        // TODO Auto-generated method stub
        for(int x=0;x<50;x++) {
            try {
                this.resource.sub();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }
}
class Resource{//定義一個操作的資源
    private int num=0;//這個要進(jìn)行加減操作的數(shù)據(jù)
    private boolean flag=true;//加減的切換
    //flag=true;表示可以進(jìn)行加法操作，但無法進(jìn)行減法操作
    //flag=false；表示可以進(jìn)行減法操作，但是無法進(jìn)行加法操作
    public synchronized void add() throws Exception {//執(zhí)行加法操作
        if(this.flag==false) {//線程需要執(zhí)行的是減法操作，加法操作要等待處理
            super.wait();
        }
        Thread.sleep(100);
        this.num++;
        System.out.println("加法操作-"+Thread.currentThread().getName()+"num="+this.num);
        this.flag=false;//加法操作執(zhí)行完畢，需要執(zhí)行減法處理
        super.notifyAll();//喚醒全部等待處理
    }
    public synchronized void sub() throws Exception {//執(zhí)行減法操作
        if(this.flag==true) {//線程需要執(zhí)行的是加法操作，減法操作要等待處理
            super.wait();
        }
        Thread.sleep(200);
        this.num--;
        System.out.println("減法操作-"+Thread.currentThread().getName()+"num="+this.num);
        this.flag=true;//減法操作執(zhí)行完畢，現(xiàn)在要執(zhí)行加法操作
        super.notifyAll();//喚醒全部等待線程
    }
}

這一題目是經(jīng)典的多線程開發(fā)操作，這個程序里面一定要考慮的核心本質(zhì)在于：加一個、減一個，整體的計(jì)算結(jié)果應(yīng)該只在0、-1、1之間循環(huán)出現(xiàn)

生產(chǎn)電腦

設(shè)計(jì)一個生產(chǎn)電腦和搬運(yùn)電腦的類，要求生產(chǎn)一臺電腦就搬走一臺電腦，如果沒有新電腦的生產(chǎn)就等待新電腦生產(chǎn)；如果生產(chǎn)出的電腦沒有搬走，則要等待電腦搬走之后再生產(chǎn)，并統(tǒng)計(jì)出電腦生產(chǎn)的數(shù)量

解答：在本程序之中實(shí)現(xiàn)的就是一個標(biāo)準(zhǔn)的生產(chǎn)者與消費(fèi)者的處理模型

public class ThreadDemo{
    public static void main(String[] args) throws Exception {
        
        Resource res=new Resource();
        new Thread(new Producer(res)).start();
        new Thread(new Consumer(res)).start();
        
    }
}
class Producer implements Runnable{
    private Resource resource;
    public Producer(Resource resource) {
        this.resource=resource;
    }
    @Override
    public void run() {
        // TODO Auto-generated method stub
        for(int x=0;x<50;x++) {
            
            this.resource.make();
        }
        
    }
    
}
class Consumer implements Runnable{
    private Resource resource;
    public Consumer(Resource resource) {
        this.resource=resource;
    }
    @Override
    public void run() {
        // TODO Auto-generated method stub
        for(int x=0;x<50;x++) {
    
            this.resource.get();
        }
        
    }
    
}
class Resource{
    private Computer computer;
    private boolean flag=true;
    public synchronized void make() {
        if(this.computer!=null) {//已經(jīng)生產(chǎn)過了
            try {
                super.wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        this.computer=new Computer("小米電腦",1.1);
        System.out.println("生產(chǎn)電腦"+this.computer);
        super.notifyAll();
    }
    public synchronized void get() {
        if(this.computer==null) {//還沒有生產(chǎn)
            try {
                super.wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        try {
            Thread.sleep(200);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("取走電腦"+this.computer);
        this.computer=null;//已經(jīng)取走了
        super.notifyAll();
    }
}
class Computer{
    private static int count=0;//表示生產(chǎn)個數(shù)
    private String name;
    private double price;
    public Computer(String name,double price) {
        this.name=name;
        this.price=price;
        count++;
    }
    public String toString(){
        return "第"+count +"臺電腦"+"電腦名字："+this.name+"、價值："+this.price;
    }
}

競爭搶答

實(shí)現(xiàn)一個競拍搶答程序：要求設(shè)置三個搶答者（三個線程），而后發(fā)出搶答指令，搶答成功給出搶答成功提示，搶答失敗給出搶答失敗提示

由于需要牽扯到數(shù)據(jù)的返回所以使用Callable更簡單

package java線程;

import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

public class ThreadDemo{
	public static void main(String[] args) throws Exception {
		
		Mythread mt=new Mythread();
		FutureTask<String> taskA=new FutureTask<String>(mt);
		FutureTask<String> taskB=new FutureTask<String>(mt);
		FutureTask<String> taskC=new FutureTask<String>(mt);
		new Thread(taskA,"競賽者A").start();
		new Thread(taskB,"競賽者B").start();
		new Thread(taskC,"競賽者C").start();
		System.out.println(taskA.get());
		System.out.println(taskB.get());
		System.out.println(taskC.get());
		
	}
}
class Mythread implements Callable<String>{
	private boolean flag=false;

	@Override
	public String call() throws Exception {
		// TODO Auto-generated method stub
		synchronized (this) {
			if(this.flag==false) {
				this.flag=true;
				return Thread.currentThread().getName()+"搶答成功";
			}
			else {
				return Thread.currentThread().getName()+"搶答失敗";
			}
			
		}
	}
	
}