У меня есть связанный список samples:
protected LinkedList<RawDataset> samples = new LinkedList<RawDataset>();
Я добавляю элементы в список в потоке 1 следующим образом:
this.samples.offer(data);
И я извлекаю элементы из него во втором потоке, например:
public RawDataset retrieveSample() {
return this.samples.poll();
}
Будет ли это рассматриваться как потокобезопасное? Несмотря на то, что нить 1 и 2 изменяют список, они делают это только по голове или хвосту списка, правда?
Если это не может кто-нибудь указать мне класс в Java API, который поставляется с poll/offer и наверняка будет потокобезопасным?
Спасибо заранее.
BTW: Collections.synchronizedList(new LinkedList()) не даст мне доступ к offer/poll.
LinkedList не является потокобезопасным. Вам нужно будет сделать запирание себя.
Попробуйте ConcurrentLinkedQueue или LinkedBlockingDeque вместо если он соответствует вашим потребностям, они являются потокобезопасными, но немного отличающимися по сравнению с LinkedList.
Если у вас есть JDK, вы можете посмотреть исходный код "Collections.synchronizedList()". Это просто, поэтому вы можете создать копию этого метода, специализированного для получения как LinkedList, так и функциональных функций синхронизации.
public class SynchronizedLinkedList<T> implements List<T> {
private LinkedList<T> list;
private Object lock;
public void add(T object) {
synchronized(lock) {
list.add(object);
}
}
// etc.
}
Нет LinkedList не является потокобезопасным. Используйте LinkedBlockingDeque вместо
Это правильно - LinkedList не синхронизирован и, следовательно, не является потокобезопасным. Если вы не хотите использовать более ранние синхронизированные аналогии LinkedList, а именно ConcurrentLinkedQueue или LinkedBlockingQueue, вы можете инициализировать LinkedList следующим образом:
LinkedList<RawDataset> samples = (LinkedList)Collections.synchronizedList(new LinkedList<RawDataset>());