- Concurrency - Discussion
- Concurrency - Useful Resources
- Concurrency - Quick Guide
- ConcurrentNavigableMap
- Concurrency - ConcurrentMap
- Concurrency - BlockingQueue
- Concurrency - Fork-Join framework
- Concurrency - Futures and Callables
- ScheduledThreadPoolExecutor
- Concurrency - ThreadPoolExecutor
- newSingleThreadExecutor
- newScheduledThreadPool
- Concurrency - newCachedThreadPool
- Concurrency - newFixedThreadPool
- ScheduledExecutorService
- Concurrency - ExecutorService
- Concurrency - Executor
- Concurrency - AtomicReferenceArray
- Concurrency - AtomicLongArray
- Concurrency - AtomicIntegerArray
- Concurrency - AtomicReference
- Concurrency - AtomicBoolean
- Concurrency - AtomicLong
- Concurrency - AtomicInteger
- Concurrency - Condition
- Concurrency - ReadWriteLock
- Concurrency - Lock
- Concurrency - ThreadLocalRandom
- Concurrency - ThreadLocal
- Concurrency - Deadlock
- Concurrency - Synchronization
- Interthread Communication
- Concurrency - Major Operations
- Concurrency - Environment Setup
- Concurrency - Overview
- Concurrency - Home
Selected Reading
- Who is Who
- Computer Glossary
- HR Interview Questions
- Effective Resume Writing
- Questions and Answers
- UPSC IAS Exams Notes
Java Concurrency - AtomicLong Class
A java.util.concurrent.atomic.AtomicLong class provides operations on underlying long value that can be read and written atomically, and also contains advanced atomic operations. AtomicLong supports atomic operations on underlying long variable. It have get and set methods that work pke reads and writes on volatile variables. That is, a set has a happens-before relationship with any subsequent get on the same variable. The atomic compareAndSet method also has these memory consistency features.
AtomicLong Methods
Following is the pst of important methods available in the AtomicLong class.
Sr.No. | Method & Description |
---|---|
1 | pubpc long addAndGet(long delta) Atomically adds the given value to the current value. |
2 | pubpc boolean compareAndSet(long expect, long update) Atomically sets the value to the given updated value if the current value is same as the expected value. |
3 | pubpc long decrementAndGet() Atomically decrements by one the current value. |
4 | pubpc double doubleValue() Returns the value of the specified number as a double. |
5 | pubpc float floatValue() Returns the value of the specified number as a float. |
6 | pubpc long get() Gets the current value. |
7 | pubpc long getAndAdd(long delta) Atomiclly adds the given value to the current value. |
8 | pubpc long getAndDecrement() Atomically decrements by one the current value. |
9 | pubpc long getAndIncrement() Atomically increments by one the current value. |
10 | pubpc long getAndSet(long newValue) Atomically sets to the given value and returns the old value. |
11 | pubpc long incrementAndGet() Atomically increments by one the current value. |
12 | pubpc int intValue() Returns the value of the specified number as an int. |
13 | pubpc void lazySet(long newValue) Eventually sets to the given value. |
14 | pubpc long longValue() Returns the value of the specified number as a long. |
15 | pubpc void set(long newValue) Sets to the given value. |
16 | pubpc String toString() Returns the String representation of the current value. |
17 | pubpc boolean weakCompareAndSet(long expect, long update) Atomically sets the value to the given updated value if the current value is same as the expected value. |
Example
The following TestThread program shows a safe implementation of counter using AtomicLong in thread based environment.
import java.util.concurrent.atomic.AtomicLong; pubpc class TestThread { static class Counter { private AtomicLong c = new AtomicLong(0); pubpc void increment() { c.getAndIncrement(); } pubpc long value() { return c.get(); } } pubpc static void main(final String[] arguments) throws InterruptedException { final Counter counter = new Counter(); //1000 threads for(int i = 0; i < 1000 ; i++) { new Thread(new Runnable() { pubpc void run() { counter.increment(); } }).start(); } Thread.sleep(6000); System.out.println("Final number (should be 1000): " + counter.value()); } }
This will produce the following result.
Output
Final number (should be 1000): 1000Advertisements