Concurrency helpers

[fh-ms]

New helpers for concurrency handling using ReentrantReadWriteLocks internally.

LockedExecutor and StripeLockedExecutor are utilities that use ReentrantReadWriteLock internally.

LockScope and StripeLockScope are abstract classes to extend. They provide protected delegates for the lock executors but hide the executor itself for even easier usage.

Use executors

public class Customers
{
	private final transient LockedExecutor executor = LockedExecutor.New();
	private final List<Customer> customers = new ArrayList<>();
	
	public void addCustomer(Customer c)
	{
		this.executor.write(() -> {
			this.customers.add(c);
			Application.storageManager().store(this.customers);
		});
	}
	
	public void traverseCustomers(Consumer<Customer> consumer)
	{
		this.executor.read(() -> this.customers.forEach(consumer));
	}
}

Or extend from a scope

public class Customers extends LockScope
{
	private final List<Customer> customers = new ArrayList<>();
	
	public void addCustomer(Customer c)
	{
		write(() -> {
			this.customers.add(c);
			Application.storageManager().store(this.customers);
		});
	}
	
	public void traverseCustomers(Consumer<Customer> consumer)
	{
		read(() -> this.customers.forEach(consumer));
	}
}

[Bios-Marcel]

This is definitely useful, we did something like that too.

However, shouldn't this be part of the store, instead of the serializer? Just wondering, maybe the question is dumb cause I missunderstood something :D

[fh-ms]

This is definitely useful, we did something like that too.

However, shouldn't this be part of the store, instead of the serializer? Just wondering, maybe the question is dumb cause I missunderstood something :D

It's part of the serializer's base module like all other common utilities, which could be useful for any other module.