<ehcache updateCheck="false"
         monitoring="on"
         dynamicConfig="false"
         name="TestCache">    
    <defaultCache maxEntriesLocalHeap="2"/>    
</ehcache>

<property name="hibernate.cache.use_second_level_cache">true</property>
<property name="net.sf.ehcache.configurationResourceName">ehcache.xml</property>
<property name="hibernate.default_batch_fetch_size">0</property>
<property name="hibernate.cache.provider_class">org.hibernate.cache.ehcache.EhCacheProvider</property>
<property name="hibernate.cache.use_structured_entries">true</property>
<property name="hibernate.cache.use_query_cache">true</property>
<property name="hibernate.cache.use_minimal_puts">true</property>
<property name="hibernate.max_fetch_depth">1</property>
<property name="hibernate.cache.region.factory_class">org.hibernate.cache.ehcache.EhCacheRegionFactory</property>

drop table if exists EhCacheDeadLockTest;
create table EhCacheDeadLockTest (`id` int not null,`value` varchar(255) not null, primary key (`id`) ) engine=InnoDB;
insert into EhCacheDeadLockTest values (1,'1');
insert into EhCacheDeadLockTest values (2,'2');
insert into EhCacheDeadLockTest values (10010003,'3');
insert into EhCacheDeadLockTest values (10010004,'4');

import org.hibernate.annotations.Cache;
import org.hibernate.annotations.CacheConcurrencyStrategy;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table( name = "EhCacheDeadLockTest" )
@Cache( usage = CacheConcurrencyStrategy.READ_WRITE )
public class EhCacheDeadLockEntity
{
	@Id
	@Column( name = "id" )
	private int id;

	@Column( name = "value" )
	private String value;

	public int getId()
	{
		return id;
	}

	public void setId( int id )
	{
		this.id = id;
	}

	public String getValue()
	{
		return value;
	}

	public void setValue( String value )
	{
		this.value = value;
	}

	@Override
	public String toString()
	{
		return "EhCacheDeadLockEntity{" +
				"id=" + id +
				", value='" + value + '\'' +
				'}';
	}

	@Override
	public boolean equals( Object o )
	{
		if ( this == o ) return true;
		if ( !( o instanceof EhCacheDeadLockEntity ) ) return false;

		EhCacheDeadLockEntity that = (EhCacheDeadLockEntity) o;

		if ( id != that.id ) return false;

		return true;
	}

	@Override
	public int hashCode()
	{
		return id;
	}
}

private static final int[] ID_LIST = new int[]{ 1, 2, 10010003, 10010004 };
static volatile boolean finish = false;
static AtomicInteger counter = new AtomicInteger();

class Worker implements Runnable
	{
		Random rnd = new Random();

		@Override
		public void run()
		{
			while ( !finish )
			{
				try
				{
					final Session session = HibernateFactory.getCurrentSession();
					Transaction tx = session.beginTransaction();
					try
					{
						session.clear();
						int id = ID_LIST[rnd.nextInt( ID_LIST.length )];
						EhCacheDeadLockEntity entity = (EhCacheDeadLockEntity) session.get( EhCacheDeadLockEntity.class, id );
						entity.setValue( String.valueOf( rnd.nextInt() ) );
						session.save( entity );
					}
					finally
					{
						tx.commit();
						counter.incrementAndGet();
					}
				}
				catch ( Throwable e )
				{
					System.out.println( e );
				}
			}
		}
	}

	@Test
	public void testDeadLock() throws Exception
	{
		final int THREAD_COUNT = 32;
		Worker[] workers = new Worker[THREAD_COUNT];
		Thread[] threads = new Thread[THREAD_COUNT];

		for ( int i = 0; i < workers.length; i++ ) workers[i] = new Worker();

		for ( int i = 0; i < workers.length; i++ ) threads[i] = new Thread( workers[i] );

		for ( int i = 0; i < workers.length; i++ ) threads[i].start();

		Thread.sleep( 5000 );
		System.out.println( "counter=" + counter.get() );
		finish = true;

		for ( int i = 0; i < workers.length; i++ ) threads[i].join();
}