详解Java利用ExecutorService实现同步执行大量线程

时间:2021-05-19

自从java1.5以后,官网就推出了Executor这样一个类,这个类,可以维护我们的大量线程在操作临界资源时的稳定性。
先上一段代码吧:

TestRunnable.java

public class TestRunnable implements Runnable { private String name; public TestRunnable(String name) { this.name = name; } @Override public void run() { while (true) { if (Main.Surplus < 0) return; Main.Surplus--; System.out.println(name + " " + Main.Surplus); } }}

main入口

public static void main(String[] args) { TestRunnable runnable = new TestRunnable("runnable1"); TestRunnable runnable2 = new TestRunnable("runnable2"); Thread t1 = new Thread(runnable); Thread t2 = new Thread(runnable2); t1.start(); t2.start(); }

这样,我们就看到了,数据肯定是乱了的,当然这个时候我们可以加上一个synchronized的关键字,但是这样也会出现点小问题的

下面我打算采用一种java内置的线程管理的机制,来解决这个问题,解决这个问题的思路大概就是,我们维护了一个线程池,当有请求操作的时候统统进入线程池,并且我们只开了一个线程,可以让请求顺序执行,顺序调用临界资源,就很安全了。

import java.util.concurrent.Callable;import java.util.concurrent.ExecutionException;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;public class Main { public static int Surplus = 10; private ExecutorService executor = Executors.newSingleThreadExecutor(); void addTask(Runnable runnable) { executor.execute(runnable); } <V> V addTask(Callable<V> callable) { Future<V> submit = executor.submit(callable); try { return submit.get(); } catch (InterruptedException e) { System.out.println("InterruptedException" + e.toString()); } catch (ExecutionException e) { System.out.println("ExecutionException" + e.toString()); } return null; } public void testAddTask(String name) { addTask(new Runnable() { @Override public void run() { for (int i = 0; i < 3; i++) { if (Main.Surplus <= 0) return; Main.Surplus--; System.out.println(name + " " + Main.Surplus); } } }); } public void testAddTask2(String name) { int count = addTask(new Callable<Integer>() { @Override public Integer call() throws Exception { for (int i = 0; i < 3; i++) { if (Main.Surplus <= 0) return 0; Main.Surplus--; System.out.println(name + " " + Main.Surplus); } return Main.Surplus; } }); } public void close() { executor.shutdown(); } public static void main(String[] args) { Main main = new Main(); main.testAddTask("task1"); main.testAddTask2("task2"); main.testAddTask("task3"); main.testAddTask2("task4"); main.close(); }}

在这里,我们定义了两种方法,分别是addTask,具有泛型的addTask,这两种方法实现原理都是一样的,其中一个是有回调的,一个是没有回调的,就看项目需求了吧。

然后分别调用这两个方法咯,就可以看到结果是非常有序,且不会混乱的。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章