摘要：本人郵箱歡迎轉載轉載請注明網址代碼已經全部托管有需要的同學自行下載引言之前我們講到都是多線程共享數據那么有沒有某一個共享的變量在這變量里面每個線程都能擁有自己的屬性呢比如說去旅店開房休息那么這個旅店就是一個共享的數據但是每個人開的房間是不一
本人郵箱:
歡迎轉載,轉載請注明網址 http://blog.csdn.net/tianshi_kco
github: https://github.com/kco1989/kco
代碼已經全部托管github有需要的同學自行下載
引言
之前我們講到都是多線程共享數據.那么有沒有某一個共享的變量,在這變量里面,每個線程都能擁有自己的屬性呢?比如說,去旅店開房休息.那么這個旅店就是一個共享的數據,但是每個人開的房間是不一樣的.這個要怎么做呢?這里我先試著寫一些
例子1
讓我們編寫一個程序,主線程開啟十個子線程,然后每個子線程都做1~100的累加,都是共享同一個List,每個線程占有固定的位置進行累加計算
public class TestMain {
public static class CalcRunnable implements Runnable{
List list ;
int index;
public CalcRunnable(List list, int index) {
this.list = list;
this.index = index;
}
@Override
public void run() {
for (int i = 1; i <= 100; i++){
list.set(index, list.get(index) + i);
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
List list = new ArrayList<>();
List threads = new ArrayList<>();
for (int i = 0; i < 10; i ++){
list.add(0);
threads.add(new Thread(new CalcRunnable(list,i)));
}
for (Thread thread : threads){
thread.start();
}
try {
Thread.sleep(1500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(list);
}
}
輸出結果為
[5050, 5050, 5050, 5050, 5050, 5050, 5050, 5050, 5050, 5050]
這里每個線程都共享了list,但是也沒有使用關鍵字synchronized進行同步,為什么結果還是正確的呢?原因很簡單,那就是每個線程都使用固定的索引進行計算,互不干擾.所以結果不會受其他線程影響的.
例子2
現在把上面的例子中的List改為Map來做累加
public class TestMain1 {
public static class CalcRunnable implements Runnable{
Map map;
public CalcRunnable(Map map) {
this.map = map;
}
@Override
public void run() {
Thread self = Thread.currentThread();
for (int i = 1; i <= 100; i++){
map.put(self, map.get(self) + i);
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
public static void main(String[] args) {
Map map = new HashMap<>();
List threads = new ArrayList<>();
for (int i = 0; i < 10; i ++){
Thread thread = new Thread(new CalcRunnable(map));
map.put(thread,0);
threads.add(thread);
}
for (Thread thread : threads){
thread.start();
}
try {
Thread.sleep(1500);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(map);
}
}
運行結果
{Thread[Thread-1,5,]=5050, Thread[Thread-3,5,]=5050, Thread[Thread-6,5,]=5050, Thread[Thread-0,5,]=5050, Thread[Thread-8,5,]=5050, Thread[Thread-5,5,]=5050, Thread[Thread-7,5,]=5050, Thread[Thread-2,5,]=5050, Thread[Thread-4,5,]=5050, Thread[Thread-9,5,]=5050}
結果也是完全正確,道理跟上面的例子一樣,每個線程雖然共用同一個數據map,但實際上每個線程都是用map中特定的那個元素
例子3
其實用map還有一種更簡單的方式,那就是今天要講的ThreadLocal,不廢話,看例子
public class TestMain3 {
public static class CalcRunnable implements Runnable{
ThreadLocal threadLocal;
public CalcRunnable(ThreadLocal threadLocal) {
this.threadLocal = threadLocal;
}
@Override
public void run() {
threadLocal.set(0);//設置默認值
for (int i = 1; i <= 100; i++){
threadLocal.set(threadLocal.get() + i);
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName() + " 的計算結果為: " + threadLocal.get());
}
}
public static void main(String[] args) {
ThreadLocal threadLocal = new ThreadLocal<>();
List threads = new ArrayList<>();
for (int i = 0; i < 10; i ++){
Thread thread = new Thread(new CalcRunnable(threadLocal));
threads.add(thread);
}
for (Thread thread : threads){
thread.start();
}
}
}
運行結果
Thread-0 的計算結果為: 5050
Thread-5 的計算結果為: 5050
Thread-1 的計算結果為: 5050
Thread-4 的計算結果為: 5050
Thread-7 的計算結果為: 5050
Thread-6 的計算結果為: 5050
Thread-3 的計算結果為: 5050
Thread-2 的計算結果為: 5050
Thread-8 的計算結果為: 5050
Thread-9 的計算結果為: 5050
原理,其實就是跟例子2的Map,在ThreadLocal中實現了一個ThreadLocalMap內部類,然后在調用ThreadLocal.get和ThreadLocal.set的時候,其實要獲取當前線程去做相應的操作.
總結
如果以后大家想讓多線程共享一個變量,但又不想互相影響的時候,那么首選ThreadLocal.因為對比上面三個例子,發現使用ThreadLocal是最簡單的,而且不容易出錯的.比如在web開發中,可以在多線程中存放session,或者數據庫連接池的時候,也可以使用ThreadLocal在存放數據庫連接.
打賞
如果覺得我的文章寫的還過得去的話,有錢就捧個錢場,沒錢給我捧個人場(幫我點贊或推薦一下)
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/67042.html
