Java多线程编程综合案例详解
作者:样子的木偶 发布时间:2023-12-09 18:13:25
标签: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拥有返回值方便我们处理
来源:https://blog.csdn.net/m0_63694520/article/details/125952930
0
投稿
猜你喜欢
- 一. CodeCache简介从字面意思理解就是代码缓存区,它缓存的是JIT(Just in Time)编译器编译的代码,简言之codeCac
- 估计学过Unix开发但是没有细致学习Java的同学们会疑惑了,操作系统里面是没有所谓的守护线程的概念,只有守护进程一说,但是Java语言机制
- 最近需要对接支付宝的支付接口,官方文档写得内容有点分散,整理了一下发布出来,用作记录,同时也希望对不了解情况的人有所帮助,这里以电脑端的网页
- Redis 简介Redis 是完全开源的,遵守 BSD 协议,是一个高性能的 key-value 数据库。Redis 与其他 key - v
- 一、IDEA自带打包插件内容:此种方式可以自己选择制作胖包或者瘦包,但推荐此种方式制作瘦包。输出:输出目录在out目录下流程步骤:第一步:
- 概述LruCache的核心原理就是对LinkedHashMap的有效利用,它的内部存在一个LinkedHashMap成员变量,值得注意的4个
- 介绍大家都知道微信支付的回调链接要求不能跟参数,但又要接收返回的xml数据。我开始使用@RequestBody注解在参数上,希望能获取xml
- 在用java的io流读写文件时,总是被它的各种流能得很混乱,有40多个类,理清啦,过一段时间又混乱啦,决定整理一下!以防再忘Java输入/输
- 1.可能是缓存导致的。解决方法:清除缓存!2.全局编译可能项目依赖别的模块,别的模块修改未进行编译,这时须先对依赖模块进行编译补充知识:ID
- 用途项目中使用了 dubbo,注册中心使用的 zookeeper,使用 zookeeper 实现了一个简单的分布式锁(依赖 curator)
- 问题描述平常用的是java8,最近在学习java的新特性。这就需要从java8往更高的java版本切换。由于还在使用java8,测试完新特性
- SimpleDateFormat是处理日期格式转换的类。官方API_1.8关于SimpleDateFormat继承于DateFormate截
- java 使用异常的好处总结一、分析Java异常处理机制确实比较慢,这个“比较慢”是相对于诸如String、Integer等对象来说,单单从
- 本文实例为大家分享了java实现双色球抽奖的具体代码,供大家参考,具体内容如下实现双色球先考虑整体思路:1.随机生成7位数的数组为大奖号码(
- 错误内容:com.alibaba.druid.pool.GetConnectionTimeoutException: wait millis
- 前言博主之前有写过关于递归问题的思维模式:递归的思路下面将用这种思维模式来求解经典汉诺塔问题。一、问题描述汉诺塔(又称河内塔)问题是源于印度
- mport java.text.DecimalFormat; DecimalFormat &nb
- 定义在一幅无向图G=(V,E) 中,(u,v) 为连接顶点u和顶点v的边,w(u,v)为边的权重,若存在边的子集T&am
- 对JVM运行参数进行修改是JVM性能调优的重要手段,下面介绍在应用程序开发过程中JVM参数设置的几种方式。方式一java程序运行时指定 -D
- 昨天有个粉丝加了我,问我如何实现类似shiro的资源权限表达式的访问控制。我以前有一个小框架用的就是shiro,权限控制就用了资源权限表达式