【JAVA】:万字长篇带你了解JAVA并发编程-并发设计模式【五】

2023-11-07 20:36

本文主要是介绍【JAVA】:万字长篇带你了解JAVA并发编程-并发设计模式【五】,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

  • 【JAVA】:万字长篇带你了解JAVA并发编程-并发设计模式【五】
    • 模式分类
    • Immutability模式【不可变模式】
    • Copy-on-Write 模式
    • Thread Local Storage 模式
        • 线程池中使用
    • Guarded Suspension模式
      • 扩展 Guarded Suspension 模式
    • Balking模式
    • Thread-Per-Message
    • Worker Thread模式 (线程池模式)
      • 角色
    • 两阶段终止模式
      • 两阶段终止模式适用于以下场景:
    • 生产者-消费者模式
    • 参考学习:

个人主页: 【⭐️个人主页】
需要您的【💖 点赞+关注】支持 💯


【JAVA】:万字长篇带你了解JAVA并发编程-并发设计模式【五】

模式分类

避免共享:Immutability模式、Copy-on-Write模式、Thread-Local-Storage模式

Immutability模式【不可变模式】

利用不可变对象解决并发问题的模式,就是不可变模式。

如果对象一旦被创建,状态就不会再发生任何变化,并且只允许存在只读方法,这个对象就是不可变对象。

要实现Immuatability模式很简单,将一个类本身及其所有的属性都设为 final ,并且方法都是只读的,需要注意的是,如果类的属性也是引用类型,那么其对应的类也要满足不可变的特性。

final 应该都很熟悉了,用它来修饰类和方法,分别表示类不可继承、属性不可改变。

Java 中具备不可变性的类型包括:
• String
• final 修饰的基本数据类型
• Integer、Long、Double 等基本数据类型的包装类
• Collections 中的不可变集合

经常用到的String对象和各种基础类型的包装类,比如,Long,Integer都具备不可变性。更进一步,基本数据类型的包装类都用到了享元模式(Flyweight Pattern), 利用享元模式(Flyweight Pattern)可以减少创建对象的数量,从而减少内存占用。Java 语言里面 Long、Integer、Short、Byte 等这些基本数据类型的包装类都用到了享元模式。

但是在使用不可变模式时,一定要搞清楚特定不可变对象的边界在哪里。

😒: 比如,一个final类C的final成员变量a,当a的内部存在非final的其他对象时,并且C中存在着get_a的public接口,那么C就不是线程安全的。

Copy-on-Write 模式

写时复制Copy-on-Write, COW或者CoW)是一种延时策略,只要在真正需要复制的时候才复制,而不是提前复制好。同时还支持按需复制COW通常用于操作系统领域提升性能。
在这里插入图片描述

在操作系统领域,除了创建进程用到了 Copy-on-Write,很多文件系统也同样用到了,例如 Btrfs (B-Tree File System)、aufs(advanced multi-layered unification filesystem)等。相比较而言,Java 提供的 Copy-on-Write 容器,由于在修改的同时会复制整个容器,所以在提升读操作性能的同时,是以内存复制为代价的。除了上面我们说的 Java 领域、操作系统领域,很多其他领域也都能看到 Copy-on-Write 的身影:Docker 容器镜像的设计是 Copy-on-Write,甚至分布式源码管理系统 Git 背后的设计思想都有 Copy-on-Write

Copy-on-Write模式适用于对数据的实时性不敏感,读多写少且对读性能要求极为苛刻的小数据场景。

具体的实现也很简单,当数据需要修改时,先复制一份出来,在复制的数据上进行修改,并发读还是在旧的数据上,当数据修改完成后,再将老数据替换为修改后的新数据即可。但需要注意的是,当发生并发写时,可以使用CAS的策略来完成。

CopyOnWriteArrayListCopyOnWriteArraySet这两个 Copy-on-Write 容器在修改的时候会复制整个数组,所以如果容器经常被修改或者这个数组本身就非常大的时候,是不建议使用的。反之,如果是修改非常少、数组数量也不大,并且对读性能要求苛刻的场景,使用 Copy-on-Write 容器效果就非常好了。

🌴 总而言之,Copy-on-Write适合对读的性能要求很高,读多写少,弱一致性场景。如Dubbo中的路由表。

Thread Local Storage 模式

线程本地存储模式(ThreadLocal)

大多数并发问题都是由于变量的共享导致的,多个线程同时读写同一变量便会出现原子性,可见性等问题。局部变量是线程安全的,本质上也是由于各个线程各自拥有自己的变量,避免了变量的共享。
Java 中使用了 ThreadLocal 来实现避免变量共享的方案。ThreadLocal 保证在线程访问变量时,会创建一个这个变量的副本,这样每个线程都有自己的变量值,没有共享,从而避免了线程不安全的问题。

线程封闭的本质就是避免共享,除了局部变量,还有Java提供的线程本地存储(ThreadLocal)也可以实现。

Java中的设计方案:
Thread拥有threadLocals属性,threadLocals属性的类型是ThreadLocalMap容器ThreadLocalMap容器中以ThreadLocalkey,维护不同类型的value。ThreadLocalMap 里对 ThreadLocal 的引用是弱引用(WeakReference),所以只要== Thread 对象可以被回收,那么 ThreadLocalMap 就能被回收==。这样不容易产生内存泄露

线程池中使用

在线程池中使用ThreadLocal很容易产生内存泄漏,原因在于线程池中线程的存活时间过长,往往都是和程序同生共死的。.

这意味着Thread持有的ThreadLocalMap一直都不会被回收,再加上ThreadLocalMap中的Entry对ThreadLocal是弱引用(WeakReference),所以只要ThreadLocal结束了自己的生命周期就可以被回收掉。但Entry中的Value是被Entry强引用的,所以即便Value的生命周期结束了,Value也是无法被回收的,从而导致内存泄漏。

那么在线程池中,我们需要自己手动释放对Value的强引用,可以使用try{}finally{}方案。

通过ThreadLocal创建的线程变量,其子线程是无法继承的,也就是通过ThreadLocal创建了线程变量V,后续该线程创建了子线程,而这个子线程中无法通过访问ThreadLocal来访问父线程的线程变量V。
Java提供了InheritableThreadLocal来支持这种特性,InheritableThreadLocal是ThreadLocal的子类,所以用法和ThreadLocal相同。我完全不建议你在线程池中使用 InheritableThreadLocal,不仅仅是因为它具有 ThreadLocal 相同的缺点——可能导致内存泄露,更重要的原因是:线程池中线程的创建是动态的,很容易导致继承关系错乱,如果你的业务逻辑依赖 InheritableThreadLocal,那么很可能导致业务逻辑计算错误,而这个错误往往比内存泄露更要命。

public class ThreadLocalTest {private static final ThreadLocal<SimpleDateFormat> threadLocal =ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));public static SimpleDateFormat safeDateFormat() {return threadLocal.get();}public static void main(String[] args) throws ExecutionException, InterruptedException {FutureTask<SimpleDateFormat> task1 = new FutureTask<>(ThreadLocalTest::safeDateFormat);FutureTask<SimpleDateFormat> task2 = new FutureTask<>(ThreadLocalTest::safeDateFormat);Thread t1 = new Thread(task1);Thread t2 = new Thread(task2);t1.start();t2.start();System.out.println(task1.get() == task2.get());//返回false,表示两个对象不相等}
}

Guarded Suspension模式

Suspension 是“挂起”、“暂停”的意思,而 Guarded 则是“担保”的意思,连在一起 就是确保挂起
当线程在访问某个对象时,发现条件不满足,就暂时挂起等待条件满足时 再次访问。

保护性暂停设计模式(Guarded Suspension) ,一般适用于 一个线程等待另外一个线程的执行结果,两个线程一一对应,可以划分为同步的设计模式.

Guarded Suspension 设计模式是很多设计模式的基础,比如生产者消费者模式,同样在 Java 并发包中的 BlockingQueue 中也大量使用到了 Guarded Suspension 设计模式。

如果你需要一个结果要源源不断的从一个线程到另外一个线程,那就需要使用生产者消费者模式->即消息队列.

Guarded Suspension 模式本质上是一种等待唤醒机制的实现,只不过 Guarded Suspension 模式将其规范化了。规范化的好处是你无需重头思考如何实现,也无需担心实现程序的可理解性问题,同时也能避免一不小心写出个 Bug 来。但 Guarded Suspension 模式在解决实际问题的时候,往往还是需要扩展的,扩展的方式有很多,本篇文章就直接对 GuardedObject 的功能进行了增强, 当然,你也可以创建新的类来实现对 Guarded Suspension 模式的扩展。Guarded Suspension 模式也常被称作 Guarded Wait 模式、Spin Lock 模式(因为使用了 while 循环去等待)。

Java的API很多都按照保护性暂停这种设计模式来的,比如 join,future.

Guarded Suspension 模式的结构图,非常简单,一个对象 GuardedObject,内部有一个成员变量——受保护的对象,以及两个成员方法——get(Predicate p)onChanged(T obj)方法。
在这里插入图片描述

 class GuardedObject<T>{//受保护的对象T obj;final Lock lock = new ReentrantLock();final Condition done = lock.newCondition();final int timeout=1;//获取受保护对象  T get(Predicate<T> p) {lock.lock();try {//MESA管程推荐写法while(p.test(obj)){done.await(timeout, TimeUnit.SECONDS);}}catch(InterruptedException e){throw new RuntimeException(e);}finally{lock.unlock();}//返回非空的受保护对象return obj;}//事件通知方法void onChanged(T obj) {lock.lock();try {this.obj = obj;done.signalAll();} finally {lock.unlock();}}// TEST@Testpublic void testGuardedObject(){SimpleThreadUtils.newLoopThread(2,"gs",1,(t)->{if (t.getNo() % 2 != 0){System.out.println("准备获取");String s = go.get(Objects::isNull);System.out.println("获取OK  " + s );}else {try {Thread.sleep(2000);go.onChanged("hello world");} catch (InterruptedException e) {throw new RuntimeException(e);}}})  ;SimpleThreadUtils.wait(1000,()->{});}
}

扩展 Guarded Suspension 模式

GuardedObject类中增加如下代码,扩展GuardedSupsensionObject 管理功能//保存所有GuardedObjectfinal static Map<Object, GuardedObject> gos=new ConcurrentHashMap<>();//静态方法创建GuardedObjectstatic <K> GuardedObject create(K key){GuardedObject go=new GuardedObject();gos.put(key, go);return go;}static <K, T> void fireEvent(K key, T obj){GuardedObject go=gos.remove(key);if (go != null){go.onChanged(obj);}}

Balking模式

在Guarded Suspension模式中,如果消息未获得返回,消费者会始终阻塞在等待条件上,但需要快速放弃也是一个常见的需求。比如,自动存盘需求中,如果文件没有改变,就无需磁盘操作。又一个更常见的需求是,单次初始化操作时,使用init变量来控制。

通常会使用一个状态变量status来控制是否存在改变,如果对原子性有要求,可以使用互斥锁,如果对原子性无特殊要求,直接使用volatile`即可。

public class Balking {/*** 已编辑*/private volatile boolean status = false;private String buffer;private String file;public synchronized void save() {System.out.println("开始保存。。。");if (!status) {System.out.println("取消保存,已经处理了");return;}writeToFile(buffer);status = false;}public synchronized void edit(String changeContent) {this.buffer = changeContent;status = true;}/*** 模拟写到文件中*/private void writeToFile(String newContent) {this.file = newContent;}public void print(){System.out.println("> file : " + this.file);}public static void main(String[] args) {Balking balking = new Balking();SimpleThreadUtils.newLoopThread(3,"balk",100,(a)->{if (a.getNo() % 3 == 0){balking.edit("hello world "  + a.getName() +":"+ Math.floor(Math.random() * 10 ));}else {balking.save();balking.print();}});SimpleThreadUtils.wait(1000,()->{});}
}

Thread-Per-Message

所谓Per, 就是 “每~” 的意思, 因此, Thread-Per-Message 模式直译过来就是 “每一个消息一个线程” 的意思, Message 在这里可以理解为 “请求” 或 “命令”, 为每个命令或请求分配一个新的线程, 由这个新线程来执行处理- 这就是 Thread-Per-Message 模式, 在该模式中, 消息的 "委托端""执行端" 是不同的线程, 消息的委托端线程会告诉执行端的线程 “这项任务交给你执行了”
在这里插入图片描述

在这里插入图片描述

public class ThreadPerMessage {public static class Host {Helper helper = new Helper();public void request(String request) {createThreadRun(() -> {helper.run(request);});}private void createThreadRun(Runnable o) {// 一般我们不直接new Thread,因为线程创建管理再java中很重,容易导致内存泄漏问题new Thread(o, UUID.randomUUID().toString()).start();// 可以使用线程池技术 juc包中的一些线程池或线程工厂进行线程的创建管理// threadFactory.newThread(o).start();}}public static class Helper {public void run(String request) {try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(Thread.currentThread().getName()+" : 执行请求 " + request);}}public static void main(String[] args) {Host host = new Host();for (int i = 0; i < 100; i++) {host.request("hello");}SimpleThreadUtils.wait(1000,()->{});}
}

线程创建

  • java.util.concurrent.·ThreadFactory·接口
  • java.util.concurrent.Executors·类获取的ThreadFactory
  • java.util.concurrent.Executor接口
  • java.util.concurrent.ExecutorService接口
  • java.util.concurrent.ScheduledExecutorService接口

Worker Thread模式 (线程池模式)

也叫ThreadPool(线程池模式)
Java语言中,·Thread-Per-Message·毕竟还是一种高消耗的并发模式,如果可以使用阻塞队列做任务池,再创建固定数量线程消费队列中的任务,这种方式也是SDK并发工具包里提供的线程池方案

线程池有很多优点,比如,避免重复创建销毁线程,能够限制创建线程的上限 等等。但需要重点关注并 设置阻塞队列 ,比如,无界的阻塞队列可能在高并发下导致OOM不建议使用,而有界的阻塞队列需要配合合理的拒绝策略。即,在创建线程池时,建议使用有界队列,并清晰的指明拒绝策略,并且,最好还能为线程赋予一个业务相关的名字,便于调试。
更重要的是,在Worker Thread模式的线程池方案中,需要时刻关注提交到线程池中的任务是否相互独立,如果任务间存在依赖关系,则可能导致线程死锁。死锁产生的原因通常是,线程池中存在相互依赖的任务。比如,线程池中的全部线程都在执行任务1,并且阻塞等待任务2的完成,当提交任务2后,当前并没有任何空闲的线程去调度执行,于是世界静止,死锁产生。

在这里插入图片描述

角色

  • Request 任务制造者
  • Channel 任务工厂
  • Worker 工人
import java.util.Date;/*** @author 孔翔* @since 2023-11-07* copyright for author : 孔翔 at 2023-11-07* java-study*/
public class WorkerThread {/*** 请求任务*/public static class RequestTask   {private final String taskName;private final Date taskDate;RequestTask(String taskName, Date taskDate) {this.taskDate = taskDate;this.taskName = taskName;}/*** Runs this operation.*/public void runTask() {try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(this.taskName + " : 任务执行完成" + ": by " + Thread.currentThread().getName());}}/*** 任务工厂处理*/public static class Channel {public final static int MAX_WORKER = 10;/*** 任务流水线。使用队列* 这里直接使用工具类,如果自己编写,可以参考** @see GuardedSuspension*/private RequestTask[] requestTasks = new RequestTask[MAX_WORKER];/*** 线程池,使用可复用,数量可控的线程池降低线程开销*/private  Worker[] workerThreadPool = new Worker[MAX_WORKER];private volatile int queueSize ;Channel(){initWorkPool();}private void initWorkPool() {for (int i = 0; i < MAX_WORKER; i++) {workerThreadPool[i] = new Worker(this,"Worker-"+ i);workerThreadPool[i].start();}}public synchronized void putRequest(RequestTask requestTask) throws InterruptedException {while (queueSize == MAX_WORKER){wait();}System.out.println("-> "+ requestTask.taskName);// 通知其他线程,queue可以put数据requestTasks[queueSize] = requestTask;queueSize++;notifyAll();// 通知消费take}public synchronized RequestTask takeRequest() throws InterruptedException {while (queueSize == 0 ){wait();}queueSize--;System.out.println("<- "+ requestTasks[queueSize].taskName);notifyAll();return requestTasks[queueSize];}}/*** 主要处理任务*/public static class Worker extends Thread {private Channel channel;public Worker(Channel channel  ,String string) {super(  string);this.channel = channel;}@Overridepublic void run() {while (true){try {// 直接使用了阻塞队列。如果自己实现这里请增加阻塞代码/*lock.lock();RequestTask request task = channel.taskRequest();while(Task = channel.taskRequest() == null){condition.await();}RequestTask requestTask = channel.taskRequest();requestTask.runTask();finally{lock.unlock();}*/RequestTask requestTask = channel.takeRequest();requestTask.runTask();} catch (InterruptedException e) {throw new RuntimeException(e);}}}}public static void main(String[] args) throws InterruptedException {Channel channel = new Channel();for (int i = 0; i < 100; i++) {channel.putRequest(new RequestTask("task:"+ i , new Date()));}SimpleThreadUtils.holdOn();}}

两阶段终止模式

Two-Phase Termination Patter
两阶段终止模式(Two-Phase Termination)是一种用于优雅终止线程或关闭应用程序的设计模式。它包含两个阶段:准备阶段终止阶段

在这里插入图片描述

前面所有的内容都是论述,如何启动多线程去执行一个异步任务。那么,如何优雅的终止线程呢?业界也有一套成熟的方案,叫做“两阶段终止”模式。即,将终止过程分成两个阶段,第一阶段由线程T1向线程T2发送终止指令,第二阶段是由线程T2响应终止指令。

在Java语言中,Java线程存在4种状态:初始状态(NEW)可运行/运行状态(RUNNABLE)休眠状态(BLOCKED,WAITING,TIMED_WAITING)终止状态(TERMINATED)。如果要让一个线程优雅的进入终止状态,一个大前提是让线程首先进入RUNNABLE状态,即,将线程从休眠状态中唤醒至可运行/运行状态,这个可以通过interrupt()方法来实现。

实现上,可以使用一个状态标志位status,在线程T1里设置T2.status后,调用T2.interrupt,将T2从可能的休眠状态中唤醒,T2检查status是否符合终止条件,如果符合,则尝试完成正确的收尾,并优雅退出。

好处:

  • 线程安全:两阶段终止模式可以确保在终止过程中不会发生并发问题,保证线程安全。
  • 可控性:通过两个明确的阶段,可以更好地控制终止过程,确保在终止前完成必要的清理和资源释放操作。
  • 可靠性:两阶段终止模式可以处理异常情况,即使在终止过程中出现异常,也能够正常地完成终止操作。
    缺点:延迟、 复杂性 、需要协作

两阶段终止模式适用于以下场景:

  • 线程终止
  • 应用程序关闭
  • 资源释放
  • 任务取消

总的来说,两阶段终止模式适用于需要优雅地终止线程或关闭应用程序,并确保在终止过程中完成必要的清理和资源释放操作的场景。

/*** @author 孔翔* @since 2023-11-07* copyright for author : 孔翔 at 2023-11-07* java-study*/
public class TwoPhaseTermination {// 两阶段终止分为两个阶段// 1. 发送终止指令//    》// 2. 执行终止操作public static class TwoPhaseThread implements Runnable {private volatile boolean stopFlag;// 1. 发送命令public void terminal(){this.stopFlag = true;}@Overridepublic void run() {while (!stopFlag) {try {Thread.sleep(1000);System.out.println(Thread.currentThread().getName() + "任务线程正在运行...");} catch (InterruptedException e) {// 执行命令Thread.currentThread().interrupt();System.out.println(Thread.currentThread().getName() + "任务线程收到终止信号,执行终止操作");}}}}public static void main(String[] args) {TwoPhaseThread twoPhaseThread = new TwoPhaseThread();Thread thread = new Thread(twoPhaseThread);thread.start();// 发送终止线程new Thread(()->{try {Thread.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("发送执行终止线程命令");stopThread(thread,twoPhaseThread);}).start();SimpleThreadUtils.holdOn();}private static void stopThread(Thread thread, TwoPhaseThread twoPhaseThread) {twoPhaseThread.terminal();thread.interrupt();}}

生产者-消费者模式

两个线程池通过一个阻塞队列连接起来,一个生产者线程池向队列添加任务,另一个消费者线程池从队列中消费任务,两个线程池并不知道对方的存在,符合架构设计上的“解耦”,支持异步,并可以通过控制两个线程池的线程数目,平衡生产者和消费者的速度差异。

并且,通过分析任务的类型,可以在消费端更精细化的进行控制。比如,如果执行单个任务的消耗与多个任务批量执行的消耗类似,则可以在大并发的场景下,消费端批量处理或者分阶段的批量处理来提高效率。
在这里插入图片描述

这个比较简单

import com.beust.ah.A;import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;/*** 生产者-消费者模式** @author 孔翔* @since 2023-11-07* copyright for author : 孔翔 at 2023-11-07* java-study*/
public class ProductConsumer {// 核心 : 阻塞队列连接public static class ConsumerRunnable<T> implements Runnable {private final BlockingQueue<T> queue;ConsumerRunnable(BlockingQueue<T> queue) {this.queue = queue;}@Overridepublic void run() {while (true) {try {T take = queue.take();handle(take);} catch (InterruptedException e) {throw new RuntimeException(e);}}}private void handle(T take) {try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println("---> 执行任务" + take.toString());}}public static class  Product<T>  {private final BlockingQueue<T> queue;Product(BlockingQueue<T> queue) {this.queue = queue;}public void create(T t ){try {queue.put(t);} catch (InterruptedException e) {throw new RuntimeException(e);}}}public static void main(String[] args) {BlockingQueue<String> queue = new ArrayBlockingQueue<>(10);ConsumerRunnable<String> consumerRunnable = new ConsumerRunnable<>(queue);Product<String> product = new Product<>(queue);new Thread(consumerRunnable).start();new Thread(()->{for (int i = 0; i < 1000; i++) {try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}product.create("i="+ i );}}).start();SimpleThreadUtils.holdOn()}}

参考学习:

https://www.jianshu.com/p/18a07025e7e0

这篇关于【JAVA】:万字长篇带你了解JAVA并发编程-并发设计模式【五】的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/366134

相关文章

Java五子棋之坐标校正

上篇针对了Java项目中的解构思维,在这篇内容中我们不妨从整体项目中拆解拿出一个非常重要的五子棋逻辑实现:坐标校正,我们如何使漫无目的鼠标点击变得有序化和可控化呢? 目录 一、从鼠标监听到获取坐标 1.MouseListener和MouseAdapter 2.mousePressed方法 二、坐标校正的具体实现方法 1.关于fillOval方法 2.坐标获取 3.坐标转换 4.坐

Spring Cloud:构建分布式系统的利器

引言 在当今的云计算和微服务架构时代,构建高效、可靠的分布式系统成为软件开发的重要任务。Spring Cloud 提供了一套完整的解决方案,帮助开发者快速构建分布式系统中的一些常见模式(例如配置管理、服务发现、断路器等)。本文将探讨 Spring Cloud 的定义、核心组件、应用场景以及未来的发展趋势。 什么是 Spring Cloud Spring Cloud 是一个基于 Spring

Javascript高级程序设计(第四版)--学习记录之变量、内存

原始值与引用值 原始值:简单的数据即基础数据类型,按值访问。 引用值:由多个值构成的对象即复杂数据类型,按引用访问。 动态属性 对于引用值而言,可以随时添加、修改和删除其属性和方法。 let person = new Object();person.name = 'Jason';person.age = 42;console.log(person.name,person.age);//'J

java8的新特性之一(Java Lambda表达式)

1:Java8的新特性 Lambda 表达式: 允许以更简洁的方式表示匿名函数(或称为闭包)。可以将Lambda表达式作为参数传递给方法或赋值给函数式接口类型的变量。 Stream API: 提供了一种处理集合数据的流式处理方式,支持函数式编程风格。 允许以声明性方式处理数据集合(如List、Set等)。提供了一系列操作,如map、filter、reduce等,以支持复杂的查询和转

Java面试八股之怎么通过Java程序判断JVM是32位还是64位

怎么通过Java程序判断JVM是32位还是64位 可以通过Java程序内部检查系统属性来判断当前运行的JVM是32位还是64位。以下是一个简单的方法: public class JvmBitCheck {public static void main(String[] args) {String arch = System.getProperty("os.arch");String dataM

详细分析Springmvc中的@ModelAttribute基本知识(附Demo)

目录 前言1. 注解用法1.1 方法参数1.2 方法1.3 类 2. 注解场景2.1 表单参数2.2 AJAX请求2.3 文件上传 3. 实战4. 总结 前言 将请求参数绑定到模型对象上,或者在请求处理之前添加模型属性 可以在方法参数、方法或者类上使用 一般适用这几种场景: 表单处理:通过 @ModelAttribute 将表单数据绑定到模型对象上预处理逻辑:在请求处理之前

eclipse运行springboot项目,找不到主类

解决办法尝试了很多种,下载sts压缩包行不通。最后解决办法如图: help--->Eclipse Marketplace--->Popular--->找到Spring Tools 3---->Installed。

JAVA读取MongoDB中的二进制图片并显示在页面上

1:Jsp页面: <td><img src="${ctx}/mongoImg/show"></td> 2:xml配置: <?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001

零基础STM32单片机编程入门(一)初识STM32单片机

文章目录 一.概要二.单片机型号命名规则三.STM32F103系统架构四.STM32F103C8T6单片机启动流程五.STM32F103C8T6单片机主要外设资源六.编程过程中芯片数据手册的作用1.单片机外设资源情况2.STM32单片机内部框图3.STM32单片机管脚图4.STM32单片机每个管脚可配功能5.单片机功耗数据6.FALSH编程时间,擦写次数7.I/O高低电平电压表格8.外设接口

Java面试题:通过实例说明内连接、左外连接和右外连接的区别

在 SQL 中,连接(JOIN)用于在多个表之间组合行。最常用的连接类型是内连接(INNER JOIN)、左外连接(LEFT OUTER JOIN)和右外连接(RIGHT OUTER JOIN)。它们的主要区别在于它们如何处理表之间的匹配和不匹配行。下面是每种连接的详细说明和示例。 表示例 假设有两个表:Customers 和 Orders。 Customers CustomerIDCus