您好,登錄后才能下訂單哦!
自從java1.5以后,官網(wǎng)就推出了Executor這樣一個類,這個類,可以維護我們的大量線程在操作臨界資源時的穩(wěn)定性。
先上一段代碼吧:
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(); }
這樣,我們就看到了,數(shù)據(jù)肯定是亂了的,當然這個時候我們可以加上一個synchronized的關(guān)鍵字,但是這樣也會出現(xiàn)點小問題的
下面我打算采用一種java內(nèi)置的線程管理的機制,來解決這個問題,解決這個問題的思路大概就是,我們維護了一個線程池,當有請求操作的時候統(tǒng)統(tǒng)進入線程池,并且我們只開了一個線程,可以讓請求順序執(zhí)行,順序調(diào)用臨界資源,就很安全了。
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,這兩種方法實現(xiàn)原理都是一樣的,其中一個是有回調(diào)的,一個是沒有回調(diào)的,就看項目需求了吧。
然后分別調(diào)用這兩個方法咯,就可以看到結(jié)果是非常有序,且不會混亂的。
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。