java線程數組

❶ java多線程同時向一個數組arraylist添加元素,遍歷這個集合

ArrayList集合是不行的，如果多線程同時添加元素，有可能產生線程安全問題，程序也有可能報錯。
例如：一個線程正准備往進去寫數據，突然切到另一個線程它先寫了進入，在切回來這個線程並不知道這個位置已經寫入了數據，所以它還是會傻傻的寫入數據，這樣另一個線程的數據就被覆蓋了。如果是一邊添加 ，一邊遍歷的話程序會產生異常。
所以要用onwritearraylist是最好的選擇，但是注意的是，添加元素時它的性能不是很好 。

❷ Java的List如何實現線程安全

Java的List如何實現線程安全？

Collections.synchronizedList(names);效率最高，線程安全

Java的List是我們平時很常用的集合，線程安全對於高並發的場景也十分的重要，那麼List如何才能實現線程安全呢 ？

加鎖

首先大家會想到用Vector，這里我們就不討論了，首先討論的是加鎖，例如下面的代碼

public class Synchronized{

private List<String> names = new LinkedList<>();

public synchronized void addName(String name ){
names.add("abc");
}
public String getName(Integer index){
Lock lock =new ReentrantLock();
lock.lock();
try {
return names.get(index);
}catch (Exception e){
e.printStackTrace();
}
finally {
lock.unlock();
}
return null;
}
}

synchronized一加，或者使用lock 可以實現線程安全，但是這樣的List要是很多個，代碼量會大大增加。

java自帶類

在java中我找到自帶有兩種方法

CopyOnWriteArrayList

CopyOnWrite 寫入時復制，它使一個List同步的替代品，通常情況下提供了更好的並發性，並且避免了再迭代時候對容器的加鎖和復制。通常更適合用於迭代，在多插入的情況下由於多次的復制性能會一定的下降。

下面是add方法的源代碼

public boolean add(E e) {
final ReentrantLock lock = this.lock; // 加鎖 只允許獲得鎖的線程訪問
lock.lock();
try {
Object[] elements = getArray();
int len = elements.length;
// 創建個長度加1的數組並復制過去
Object[] newElements = Arrays.Of(elements, len + 1);
newElements[len] = e; // 賦值
setArray(newElements); // 設置內部的數組
return true;
} finally {
lock.unlock();
}
}

Collections.synchronizedList

Collections中有許多這個系列的方法例如

主要是利用了裝飾者模式對傳入的集合進行調用 Collotions中有內部類SynchronizedList

static class SynchronizedList<E>
extends SynchronizedCollection<E>
implements List<E> {
private static final long serialVersionUID = -7754090372962971524L;

final List<E> list;

SynchronizedList(List<E> list) {
super(list);
this.list = list;
}
public E get(int index) {
synchronized (mutex) {return list.get(index);}
}
public E set(int index, E element) {
synchronized (mutex) {return list.set(index, element);}
}
public void add(int index, E element) {
synchronized (mutex) {list.add(index, element);}
}
public E remove(int index) {
synchronized (mutex) {return list.remove(index);}
}

static class SynchronizedCollection<E> implements Collection<E>, Serializable {
private static final long serialVersionUID = 3053995032091335093L;

final Collection<E> c; // Backing Collection
final Object mutex; // Object on which to synchronize

這里上面的mutex就是鎖的對象 在構建時候可以指定鎖的對象 主要使用synchronize關鍵字實現線程安全

/**
* @serial include
*/
static class SynchronizedList<E>
extends SynchronizedCollection<E>
implements List<E> {
private static final long serialVersionUID = -7754090372962971524L;

final List<E> list;

SynchronizedList(List<E> list) {
super(list);
this.list = list;
}
SynchronizedList(List<E> list, Object mutex) {
super(list, mutex);
this.list = list;
}
這里只是列舉SynchronizedList ，其他類類似，可以看下源碼了解下。

測試
public class Main {
public static void main(String[] args) {
List<String> names = new LinkedList<>();
names.add("sub");
names.add("jobs");
// 同步方法1 內部使用lock
long a = System.currentTimeMillis();
List<String> strings = new CopyOnWriteArrayList<>(names);
for (int i = 0; i < 100000; i++) {
strings.add("param1");
}
long b = System.currentTimeMillis();
// 同步方法2 裝飾器模式使用 synchronized
List<String> synchronizedList = Collections.synchronizedList(names);
for (int i = 0; i < 100000; i++) {
synchronizedList.add("param2");
}
long c = System.currentTimeMillis();
System.out.println("CopyOnWriteArrayList time == "+(b-a));
System.out.println("Collections.synchronizedList time == "+(c-b));
}
}

兩者內部使用的方法都不一樣，CopyOnWriteArrayList內部是使用lock進行加鎖解鎖完成單線程訪問，synchronizedList使用的是synchronize

進行了100000次添加後時間對比如下：

可以看出來還是使用了synchronize的集合工具類在添加方面更加快一些，其他方法這里篇幅關系就不測試了，大家有興趣去試一下。

❸ java涓鍒╃敤澶氱嚎紼嬪規暟緇勫艱繘琛屼慨鏀癸紝涓轟粈涔堜笉鏄鎯寵佺殑緇撴灉錛

騫朵笉鏄杈撳嚭涓嶄細鍑虹幇浣犳兂瑕佺殑錛岋紝澶氬幓鎵句笅綰跨▼鏂歸潰鐨勮祫鏂欑湅鐪嬶紝錛

娌℃湁寰楀埌浣犳兂瑕佺殑鍊兼槸鍥犱負綰跨▼鎵ц岄『搴忛犳垚鐨勶紝錛岄栧厛浣犺繖涓紼嬪簭榪愯岃搗鏉ユ誨叡鏈変笁涓綰跨▼

涓葷嚎紼嬶紝綰跨▼t1錛岀嚎紼媡2

瀹為檯涓奵pu澶勭悊綰跨▼鐨勬椂鍊欏苟涓嶆槸鐪熸ｇ殑鍚屾椂榪涜岋紝鑰屾槸鎵ц屾煇涓綰跨▼涓孌墊椂闂達紝鐒跺悗鍦ㄦ墽琛屽叾浠栫嚎紼嬩竴孌墊椂闂達紝涓鐩磋繖鏍峰驚鐜涓嬪幓

綰跨▼鐨勬墽琛岄『搴忔槸涓嶅畾鐨勶紝涓嶆槸姣忔￠兘鏄痶1鍏堬紝t2鍚庯紝鎵ц岄『搴忓拰綰跨▼鐨勪紭鍏堢駭鏈夊叧緋伙紝鍦ㄧ嚎紼嬩紭鍏堢駭閮界浉鍚岀殑鎯呭喌涓嬶紝鎵ц屾潈鏄闅忔満鍒嗛厤鐨勶紝錛屼篃灝辨槸璇村彲鑳借繖嬈t1鍏堟墽琛岋紝涓嬫″嵈鏄痶2鍏堟墽琛岋紝鎵浠ヤ綘瑕佺殑緇撹炬槸鍙鑳藉嚭鐜扮殑錛岋紝浣嗘槸涓嶆槸姣忔￠兘鏄浣犳兂瑕佺殑緇撹撅紝錛岃屼笖涓鑸鎯呭喌涓嬪氱嚎紼嬪苟鍙戣塊棶鏁版嵁鐨勬椂鍊欙紝鎴戜滑閮戒細鍋氬悓姝ュ勭悊錛岄伩鍏嶆暟鎹鍑虹幇緔婁貢錛

褰撲富綰跨▼闅忔満鍒版墽琛屾潈錛岄偅涔堜富綰跨▼鍏堟墽琛岋紝鎵浠ヨ繖鏃跺欒幏鍙栧埌鐨勬暟鎹灝卞彲鑳芥槸鍘熷嬫病鏀瑰彉鐨勫礆紝錛屽綋t1鎴杢2闅忔満鍒版墽琛屾潈錛岄偅涔堣幏鍙栫殑鏁版嵁灝辨槸琚淇鏀硅繃鐨勶紝錛屼絾鏄淇鏀圭殑緇撴灉鏄鏃犺勫緥鐨勶紝錛

涓嬮潰鏄甯浣犱慨鏀逛簡涓嬬殑錛岋紝濡傛灉榪樹笉鏄浣犵殑緇撴灉錛屽彲浠ユ妸Thread.sleep(鏃墮棿)涓鐨勬椂闂磋皟澶т竴鐐

publicclassHappy

{

staticintarr[]={1,2,3,4,5};

publicstaticvoidresult()

{

Bolg1p1=newBolg1(arr);

Bolg2p2=newBolg2(arr);

Threadt1=newThread(p1);

Threadt2=newThread(p2);

t1.start();

t2.start();

}

publicstaticvoidmain(String[]args)throwsException

{

Happy.result();

Thread.sleep(1000);//鏆傚仠涓葷嚎紼1縐掞紝錛岀瓑寰呭叾浠栫嚎紼嬫墽琛

for(intm:arr)

{

System.out.println(m+"");

}

}

}

classBolg1implementsRunnable

{

int[]arr;

publicBolg1(int[]arr)

{

this.arr=arr;

}

publicvoidrun()

{

for(inti=0;i<arr.length;i+=2)

{

arr[i]=10;

}

}

}

classBolg2implementsRunnable

{

int[]arr;

publicBolg2(int[]arr)

{

this.arr=arr;

}

publicvoidrun()

{

for(intj=1;j<arr.length;j+=2)

{

arr[j]=11;

}

}

}

❹ java中怎麼用多個線程同時對一個文件讀取，最終將文件內容保存到一個位元組數組中去呢

多線程讀取文件在一塊硬碟上沒用，瓶頸在硬碟I/O，而不在CPU和內存。讀取文件時，CPU不用復雜的計算工作，只是數據傳輸而已，多線程反而造成磁頭來回移動，效率不高。如果是兩塊以上的硬碟，可以用不同的線程訪問不同的硬碟，效率比單線程要高
而且多線程操作同一文件除了效率還會有多線程問題，多個線程同時往數組里存數據還會有線程安全問題，如果不同步處理讀取的文件就是錯誤的。
如果讀取的話只能設置每個線程各自讀取偏 移量
讀取文件大小（比如大小是200K）。 2，啟動5個線程，第一個線程讀到40，第二個線程跳過40在讀到80，總之得合理安排好各個線程讀取的大小。這樣才能不重復讀取。大數據處理框架maprece原理和此類似

❺ JAVA開啟三個線程，去讀取數組中的數據不能重復

set中是不能存在重復數的。
這個可以通過修改數據的時間來判斷。例如：表中有個欄位讀取時間。當這個客戶讀取10條數據的時候，更新讀取時間為當前時間。然後下個客戶讀取的時候，判斷時間在半個小時內，沒有更新的數據。就OK了。