您的位置：首页 > 编程语言 > Java开发

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

2017-03-28 09:24 756 查看

自从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，这两种方法实现原理都是一样的，其中一个是有回调的，一个是没有回调的，就看项目需求了吧。

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

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

您可能感兴趣的文章:

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签： java executorservice

相关文章推荐

新的分享

章节导航