diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-01-19 18:15:51 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-01-19 18:15:51 -0800 |
| commit | e69fb8c75aab7b95abf03785c3b2f1384373003a (patch) | |
| tree | d153f0e41543d1ec9b837845457d8e4d4c982d80 /project | |
| parent | 74de94ea6db96a04b278c6106264313504d7b8f3 (diff) | |
| download | spark-e69fb8c75aab7b95abf03785c3b2f1384373003a.tar.gz spark-e69fb8c75aab7b95abf03785c3b2f1384373003a.tar.bz2 spark-e69fb8c75aab7b95abf03785c3b2f1384373003a.zip | |
[SPARK-5214][Core] Add EventLoop and change DAGScheduler to an EventLoop
This PR adds a simple `EventLoop` and use it to replace Actor in DAGScheduler. `EventLoop` is a general class to support that posting events in multiple threads and handling events in a single event thread.
Author: zsxwing <zsxwing@gmail.com>
Closes #4016 from zsxwing/event-loop and squashes the following commits:
aefa1ce [zsxwing] Add protected to on*** methods
5cfac83 [zsxwing] Remove null check of eventProcessLoop
dba35b2 [zsxwing] Add a test that onReceive swallows InterruptException
460f7b3 [zsxwing] Use volatile instead of Atomic things in unit tests
227bf33 [zsxwing] Add a stop flag and some tests
37f79c6 [zsxwing] Fix docs
55fb6f6 [zsxwing] Add private[spark] to EventLoop
1f73eac [zsxwing] Fix the import order
3b2e59c [zsxwing] Add EventLoop and change DAGScheduler to an EventLoop
Diffstat (limited to 'project')
0 files changed, 0 insertions, 0 deletions