I have an object whose internal mutable state is being constantly updated by one or more threads. The object is synchronized, and the goal is to periodically save its state (via serialization) from yet another thread:
public class Counter implements Serializable {
private int dogCount;
private int catCount;
public synchronized void updateFromDogThread( int count ) {
dogCount = count;
}
public synchronized void updateFromCatThread( int count ) {
catCount = count;
}
}
Questions:
- Is serialization safe in this case?
- How does it work under the hood? That is to say, will the
ObjectOutputStream
performing the serialization block until no threads are any longer operating onCounter
? - What if
Counter
's synchronization doesn't use the intrinsic lock, but some other lock?
No. As @Tom Hawtin says, you will need to perform your own locking to ensure that the object(s) are not changed while you are serializing them.
ObjectOutputStream
does no locking under the hood. It is up to the application to do this, if it is necessary.Then your application will also need to use that other lock to lock out updates while serialization is happening.
If the state that you are serializing simply consists of the state of one object with two fields, then lock contention and granularity should not be a problem. But if the object(s) are complicated, then lock contention could well be problematic, as could the problem of acquiring the locks without risking deadlock. That scenario would require careful design.
It's not safe, but it is relatively easy to make it so:
As you noticed, the object locked is arbitrary, so how would the serialisation mechnaism know how to obtain the relevant lock. Worse than that, the order of serialising and object graph is also quite arbitrary, so any attempt to lock would often lead to deadlocks. Even with the solution above, you are performing a complex operation within a lock, so be careful about deadlocks.
Whenever it's necessary to modify the serialization of a class you have to implement the special private method
void writeObject(ObjectOutputStream)
. TheObjectOutputStream
uses this method instead of the default algorithm then.In your case you want the serialization to be synchronized with the object. So all you have to do is adding the
synchronized
keyword to the method. You can still use the default implementationdefaultWriteObject
: