coherence 12.1.3 asynchronous processors

<Insert Picture Here>

Asynchronous EntryProcessorsHarvey RajaConsulting Member Technical Staff, Cloud Application FoundationOracle Coherence

Oracle Fusion Middleware 12c Cloud Application Foundation

YouTube Video Series

Copyright © 2014, Oracle and/or its affiliates. All rights reserved.2 2 Copyright © 2013, Oracle and/or its affiliates. All rights reserved.

Insert Information Protection Policy Classification from Slide 8

The following is intended to outline our general product direction. It is intended for information purposes only,

and may not be incorporated into any contract. It is not a commitment to deliver any material, code, or

functionality, and should not be relied upon in making purchasing decisions.

The development, release, and timing of any features or functionality described for Oracle’s products remain

at the sole discretion of Oracle.

Copyright © 2014, Oracle and/or its affiliates. All rights reserved.3

Agenda

EntryProcessor Introduction

Why synchronous may not be required

Asynchronous is easy

Asynchronous EntryProcessor Introduction


EntryProcessor Introduction

Avoids lock(K), get(K), mutate(V), put(K, V), unlock(K)

Executed on the member that owns K

Possible to be invoked with a Collection<K> or a Filter (Predicate)

Allow features such as Partition Lite Transactions


EntryProcessor with Single Key


EntryProcessor with Multiple Keys


Must the request be Synchronous?

Are the steps in a processing pipeline parallelizable?

If so the answer is simple:


AsynchronousProcessor

As of 12.1.3 OOTB we provide an AsynchronousProcessor

Wrapper processor

AsynchronousProcessor extends AsyncAgent implements Future

Can specify – Unit of Order {default: Thread.getId()}– Automatic Flow Control {default: true}


Demo


Join the Coherence Communityhttp://coherence.oracle.com

@OracleCoherence

facebook.com/OracleCoherence

blogs.oracle.com/OracleCoherence

Oracle Coherence Users

youtube.com/OracleCoherence

coherence.oracle.com/display/CSIGCoherence Special Interest Group

coherence 12.1.3 asynchronous processors

Technology