溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
自從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，這兩種方法實現原理都是一樣的，其中一個是有回調的，一個是沒有回調的，就看項目需求了吧。
然后分別調用這兩個方法咯，就可以看到結果是非常有序，且不會混亂的。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
