summaryrefslogtreecommitdiff
path: root/test/actor
Commit message (Collapse)AuthorAgeFilesLines
* [tests] Fix -Werror=shadow issues in the unit testsThiago Marcos P. Santos2019-12-122-120/+81
|
* [core] Introduce Pass<> class and use it for SchedulerMikhail Pozdnyakov2019-12-021-1/+1
| | | | Thus we enforce client to retain the returned `Scheduler` objects.
* [core] Introduce Scheduler::makeWeakPtr()Mikhail Pozdnyakov2019-10-091-0/+2
|
* [core] Decouple Scheduler interface from actor modelMikhail Pozdnyakov2019-10-041-1/+1
| | | | So that it is possible to schedule normal `std::function` and use `mapbox::base::WeakPtr`.
* [core] Make the BackgroundScheduler a singletonThiago Marcos P. Santos2019-05-102-59/+40
| | | | | | | | | | - Do not carry it over everywhere as parameter, it is a shared instance anyway and the lifecycle is pretty much the app lifecycle from the moment we instantiate a map. - Rename to BackgroundScheduler because it is a Scheduler that will do tasks in the background, we don't make assumptions if it is a thread pool or a single thread. - Most importantly, remove the dependency from `core` on `platform`.
* [core] clang-tidy fixesKonstantin Käfer2019-04-051-1/+1
|
* [core] Avoid blocking in Thread<Object> constructor (#12151)Anand Thakker2018-07-031-14/+85
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * Introduce AspiringActor, EstablishedActor This pair of objects represents the two-phase (parent-thread / child-thread) construction that's needed to support constructing Thread<Object> without blocking until the child thread is up and running. An `AspiringActor<O>` is responsible for: - ownership of the actor's `Mailbox` - allocating the memory for (but *not* constructing) the target object `O` Using these two pieces--the mailbox and a stable address for `O`--an `AspiringActor<O>` can accept messages for the target object, or provide `ActorRef<O>`s that do so, before the object has actually been constructed by the corresponding `EstablishedActor<O>`. (Such messages are queued in the mailbox until after the object is constructed.) This allows for an `AspiringActor<O>` to be created and safely used by a thread other than the one on which the target object will (eventually) live. An `EstablishedActor<O>` is responsible for managing the lifetime of the target object `O` and the open/closed state of the parent's `mailbox`. The `O` object's lifetime is contained by that of its owning `EstablishedActor<O>`: the `EstablishedActor` constructor executes the `O` constructor via "placement new", constructing it at the address provided by the parent `AspiringActor`, and the `~EstablishedActor` destructor similarly executes the `~O` destructor (after closing the mailbox). `EstablishedActor` should therefore live entirely on the thread intended to own `O`. * Remove Actor#{invoke,ask}
* [core] Actor/ActorRef - ask calls to void methodsIvo van Dongen2017-09-222-0/+44
| | | | - allows to wait for execution of void methods as well as non-void methods
* [core] make actor self reference optional - againIvo van Dongen2017-08-081-0/+31
| | | | - uses a different method of constructor selection that also works on Apple clang < 8.2.
* [core] Removed unused constructorupstream/tvn-test-ci-time-outThiago Marcos P. Santos2017-08-071-31/+0
| | | | | | | | | | Not in use at the moment, was causing a compiler error on Apple LLVM version 8.0.0 (clang-800.0.42.1). ``` src/mbgl/sprite/sprite_loader.cpp:25:11: error: call to constructor of 'Actor<mbgl::SpriteLoaderWorker>' is ambiguous ```
* [core] make actor self reference optionalIvo van Dongen2017-07-241-0/+31
|
* [core] add ask pattern to actor refIvo van Dongen2017-07-241-3/+55
|
* [core] implement ask pattern in actorIvo van Dongen2017-07-241-0/+24
|
* [core] add test to demonstrate waiting threads in mailbox::receive won't ↵Ivo van Dongen2017-05-271-0/+56
| | | | crash on self-closing
* [core] allow self closing mailbox/actorIvo van Dongen2017-05-271-0/+32
|
* [core] Block in Mailbox::close() until neither receive nor push are in progressJohn Firebaugh2017-05-241-1/+57
| | | | | | | | | | | | | | Otherwise, an ActorRef that's in the process of sending a message could attempt to access an invalid Scheduler reference: Thread 1 Thread 2 -------------------------------------------------- Scheduler::Scheduler Actor::Actor weakMailbox.lock() Actor::~Actor Scheduler::~Scheduler mailbox->push() scheduler.schedule() 💣
* [build] move default ThreadPool implementation to platform/defaultKonstantin Käfer2016-11-222-2/+2
|
* [core] [node] pass thread pool impl to Map constructorMike Morris2016-10-202-2/+2
| | | | | | | Updates mbgl::Map constructor usage everywhere Adds NodeThreadPool implementation using AsyncQueue to call Nan::AsyncQueueWorker from main thread
* [test] add .test.cpp suffix to test case filesKonstantin Käfer2016-09-282-0/+0
|
* [core] Use an actor model for tile worker concurrencyJohn Firebaugh2016-09-162-0/+181