Java多线程编程综合案例详解
更新时间：2022年07月26日 14:05:08 作者：样子的木偶
这篇文章将通过三个案例带大家了解一下Java中的多线程编程，文中的示例代码介绍详细，对我们的学习或工作有一定的价值，感兴趣的小伙伴可以了解一下
Java多线程综合案例
数字加减
设计4个线程对象，两个线程执行减操作，两个线程执行加操作
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;//这个要进行加减操作的数据
private boolean flag=true;//加减的切换
//flag=true;表示可以进行加法操作，但无法进行减法操作
//flag=false；表示可以进行减法操作，但是无法进行加法操作
public synchronized void add() throws Exception {//执行加法操作
if(this.flag==false) {//线程需要执行的是减法操作，加法操作要等待处理
super.wait();
}
Thread.sleep(100);
this.num++;
System.out.println("加法操作-"+Thread.currentThread().getName()+"num="+this.num);
this.flag=false;//加法操作执行完毕，需要执行减法处理
super.notifyAll();//唤醒全部等待处理
}
public synchronized void sub() throws Exception {//执行减法操作
if(this.flag==true) {//线程需要执行的是加法操作，减法操作要等待处理
super.wait();
}
Thread.sleep(200);
this.num--;
System.out.println("减法操作-"+Thread.currentThread().getName()+"num="+this.num);
this.flag=true;//减法操作执行完毕，现在要执行加法操作
super.notifyAll();//唤醒全部等待线程
}
}
这一题目是经典的多线程开发操作，这个程序里面一定要考虑的核心本质在于：加一个、减一个，整体的计算结果应该只在0、-1、1之间循环出现
生产电脑
设计一个生产电脑和搬运电脑的类，要求生产一台电脑就搬走一台电脑，如果没有新电脑的生产就等待新电脑生产；如果生产出的电脑没有搬走，则要等待电脑搬走之后再生产，并统计出电脑生产的数量
解答：在本程序之中实现的就是一个标准的生产者与消费者的处理模型
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) {//已经生产过了
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("生产电脑"+this.computer);
super.notifyAll();
}
public synchronized void get() {
if(this.computer==null) {//还没有生产
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;//已经取走了
super.notifyAll();
}
}
class Computer{
private static int count=0;//表示生产个数
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;
}
}
竞争抢答
实现一个竞拍抢答程序：要求设置三个抢答者（三个线程），而后发出抢答指令，抢答成功给出抢答成功提示，抢答失败给出抢答失败提示
由于需要牵扯到数据的返回所以使用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()+"抢答失败";
}
}
}
}
使用Callable的主要原因是因为Callable拥有返回值方便我们处理
到此这篇关于Java多线程编程综合案例详解的文章就介绍到这了,更多相关Java多线程编程内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
在日常操作中,相信很多人对Java启动参数存在疑惑,下面这篇文章主要给大家介绍了关于java启动参数之谜的排查过程,文中通过实例代码介绍的非常详细,需要的朋友可以参考下2022-06-06
SpringBoot中的异步事件机制通过事件源和事件监听器的解耦,实现了松耦合的组件间通信,事件源发布事件,监听器异步处理事件,本文介绍在SpringBoot中灵活使用异步事件的操作,感兴趣的朋友一起看看吧2025-03-03
Spring MVC学习之DispatcherServlet请求处理详析
这篇文章主要给大家介绍了关于Spring MVC学习教程之DispatcherServlet请求处理的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2018-11-11
字节码增强技术就是一类对现有字节码进行修改或者动态生成全新字节码文件的技术。本文将通过示例详细说说Java的字节码增强技术，需要的可以参考一下2022-10-10
同一种类型数据的集合。其实数组就是一个容器。运算的时候有很多数据参与运算,那么首先需要做的是什么下面我们就一起来看看。2016-07-07
这篇文章介绍了Java设计模式之迭代器模式，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-10-10
这篇文章主要介绍了浅谈JSONObject的使用及示例代码(JSON解析),本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-01-01
今天小编就为大家分享一篇java 二进制数据与16进制字符串相互转化方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-07-07
这篇文章主要介绍了建议你使用LocalDateTime而不是Date，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-10-10
这篇文章主要介绍了springboot如何解决前后端分离时的跨域问题，帮助大家更好的理解和学习使用springboot，感兴趣的朋友可以了解下2021-04-04
最新评论