Concurrency is hard because we haven't figure out how to make it easy. For most developers, specifically web developers, concurrency doesn't really matter. I envy that assuasive confident feeling of a sequential execution of http requests. The number of cores on my machine quadrupled in last three years and I don't know a single reliable, comforting (easy) way of harnessing it as much as possible, I feel a little sad about current state of concurrency support.
Utilizing all the processing power consistently is a lot easier for well defined and not so concurrent tasks such as map-reduce. I have done it a lot, processing gigabytes of data by reducing the problem to independent subsets is programmatic triviality. On the other hand, I have always found developing a relatively concurrent application the "right way" to be a nightmare. Concurrency applications come in two mutually exclusive flavours: slow or complex.
At this point enthusiasts will point out java.util.concurrent and move on. While j.u.concurrent is nice and a significant improvement over explicit synchronization, it still mandates that API users be concurrency wizards and its complexity exposure is nearly at par with explicit synchronization. Here's one example blog post explaining common gotcha with ConcurrentHashMap. The only benefit j.u.concurrency provides is finer grained control over where to do CAS. I am a huge fan of j.u.concurrent and have been using it pre-1.5 but I still don't think it makes concurrency so easy. For one more example,
synchronized(this){ aRef = newVal; return aRef;}
v/s
while (true) {
V x = atomicRef.get();
if (atomicRef.compareAndSet(x, newValue))
return atomicRef.get();
}
Which one do you think is easier to grasp?
Many people think that Actors are the next big thing to tackle concurrency monster and complexities introduced by these shared memory model primitives. I too initially thought so, but then I found that Actor model isn't really the sweet spot in practice as it is touted. The very notion that Actors can fail and code must handle the tricky bits to recover from it makes it even more complex than using locks/mutexes etc. I am in constant a awe to see people talking so lightly about fault tolerant/fail safe systems without giving thought on the amount of complexity it adds. I am not necessarily protesting that philosophy but that behaviour is just not common in yer average regular applications (will your user be happy if one actor failed to process her payment and was asked to retry?). We still live in dark ages of transparent concurrency.
I remain as ignorant and unsatisfied about concurrency support as I was several years ago. For me, concurrency is hard so I am off to shopping!
5 comments:
I think you have a JMM problem here depending on if the aRef is or is not volatile
synchronized(this){ aRef = newVal;} return aRef;
It could be that the aRef is updated by another thread after the {...} logic is executed. This could lead to various jmm problems.
It is better to use this:
synchronized(this){
aRef = newVal;
return aRef;
}
But I agree that concurrency can be hard and having it all over the place in a normal system, doesn't make me a happy man.
Ps:
the following code can be simplified:
while (true) {
V x = atomicRef.get();
if (atomicRef.cas(x,newValue))
return atomicRef.get();
}
To
atomicRef.set(newValue)
return newValue
No need to do that in a loop.
I agree with your first suggestions but not with second one, the atomicity is only guaranteed if you use atomicRef.get() see correct implementation for getAndSet() http://www.docjar.com/html/api/java/util/concurrent/atomic/AtomicReference.java.html
Thanks for pointing out the typo!
Not sure why URLs was truncated. Here's the link
AtomicReference
Hi Nirav,
I know the AtomicXXX implementations very well.
The operation you want to do, setting a value, doesn't need more 'atomicity' than an atomic set. The new value is a local variable and not subject to any currency issues.
For the getAndSet it is a different matter since you want to have the value that existed prior to doing the write, so the get and set needs to be atomic, hence you need to do it in a loop and use a compareAndSwap.
Peter Veentjer
Multiverse:Software Transactional Memory for the JVM
http://multiverse.codehaus.org
Post a Comment