Comments (2)
I think the following options would be useful
single-threaded (optionally non blocking)
sync synchronous execution of a FutureStream, but not on the calling thread (i.e. can be non-blocking to the calling thread via the run method). Would get it's own thread to execute on from a pool.
possibly cpuSync synchronous execution of a FutureStream on a single thread, but not on the calling thread, using common ForkJoinPool (or same Thread pool as cpuStream) see below
multi-threaded (optionally non blocking)
IOStream for creating IO bound Streams. The first action would be async (i.e. tasks passed to task executor), subsequent tasks would execute synchronously on the calling thread. Note the first action doesn't have to be IO related, the first stage being async distributes the work to separate workers. Users can manually change this behaviour via async / sync operators on FutureStreams. (Can be non-blocking to the calling thread)
cpuStream for creating CPU bound streams, would probably reuse the common ForkJoinPool, first action would be async (i.e. tasks passed to a task executor to distribute the work load), subsequent tasks would execute synchronously on the calling thread. Users can manually change this behaviour via async / sync operators on FutureStreams. (Can be non-blocking to the calling thread)
switchIO could be used to switch a Stream optimised for CPU bound execution into one optimised for IO Bound execution
switchCPU could be used to switch a Stream optimised for IO bound execution into one optimised for CPU Bound execution
from micro-server.
Available on Master
from micro-server.
Related Issues (20)
- Update Micro-server to latest version of cyclops and cyclops-React HOT 1
- Common interface for DistributedCache in micro-server HOT 1
- Upgrade micro-server to latest version of cylops and cyclops-react HOT 1
- Remove compile dependancy on lombok HOT 1
- Rename Elasti-cache plugin to micro-memcached
- GenericEvent in micro-event plugin HOT 1
- Define useful toString() on FormattedErrorCode
- API changes report for Microserver Core
- Upgrade to Cyclops X: M2 HOT 1
- Message on service startup is incorrect. HOT 1
- Upgrade hibernate as it is not compatible with the latest version of mysql-connector HOT 1
- Add ip to service-registry plugin
- Upgrade to cyclops 10.0.3
- Upgrade to Spring 5
- Upgrade to Spring Boot 2.1.0
- Work as pure Microservices Plugin offering for Spring Boot
- Remove unneeded modules
- Rename aws modules to make aws clear in the name
- Broken micro-server url
- Add GarbageCollectorMXBean to micro-jmx-metrics
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from micro-server.