- May 11, 2018
-
-
Carl Lerche authored
-
sbstp authored
-
Carl Lerche authored
Currently, not specifying a `Handle` is different than using `Handle::default()`. This is because `Handle::default()` will immediately bind to the reactor for the current context vs. not specifying a `Handle`, which binds to a reactor when it is polled. This patch changes the `Handle::default()` behavior, bringing it inline with actual defaults. `Handle::current()` still immediately binds to the current reactor. Fixes #307
-
Marek Kotewicz authored
-
- May 08, 2018
-
-
Thijs Vermeir authored
-
Julian Tescher authored
-
- May 04, 2018
-
-
Thijs Vermeir authored
-
- May 03, 2018
-
-
Thijs Vermeir authored
-
- May 02, 2018
-
-
Carl Lerche authored
-
Carl Lerche authored
-
Carl Lerche authored
This patch adds a new crate: tokio-fs. This crate provides a wrapper around `std` functionality that can only be performed using blocking operations. This primarily includes filesystem operations, but it also includes standard input, output, and error access as these streams cannot be safely switched to non-blocking mode in a portable way. These wrappers call the `std` functions from within a `blocking` annotation which allows the runtime to compensate for the fact that the thread will potentially remain blocked in a system call.
-
Carl Lerche authored
Currently, the state of the futures2 integration is pretty broken. This patch removes the feature flag, preventing users from trying to use it. In the future, it can be brought back when the implementation is fixed.
-
Roman authored
This patch introduces a version of `Runtime` that runs all components on the current thread. This allows users to spawn futures that do not implement `Send`.
-
- May 01, 2018
-
-
Stefan Bühler authored
The nested `Park` might need to do some work, even if the duration is 0 seconds (e.g. a `Reactor`). Similar to what #313 did for CurrentThread.
-
Stefan Bühler authored
-
Stefan Bühler authored
-
- Apr 30, 2018
-
-
Roman authored
-
- Apr 28, 2018
-
-
Carl Lerche authored
This also adds a filter for another treiber stack expected data race. The race is expected as part of the algorithm.
-
- Apr 25, 2018
-
-
Sebastian Dröge authored
This ensures that all fd-based futures are put into the queue for the current tick, if the CurrentThread is parking via the Reactor. Otherwise, if there are queued up futures already, only those would be polled in the turn. These futures could then notify others/themselves to have the queue still non-empty on the next turn. Which then potentially allows the reactor to never be polled, and thus fd-based futures are never queued up and polled. Also return in the Turn return value whether any futures were polled at all, which allows the caller to know if any work was done at all in this turn and based on that adjust behavior.
-
- Apr 15, 2018
-
-
Carl Lerche authored
This patch adds a `blocking` to `tokio-threadpool`. This function serves as a way to annotate sections of code that will perform blocking operations. This informs the thread pool that an additional thread needs to be spawned to replace the current thread, which will no longer be able to process the work queue.
-
- Apr 10, 2018
-
-
Carl Lerche authored
Closes #302
-
Roman authored
-
Roman authored
-
- Apr 09, 2018
-
-
Sam Rijs authored
-
- Apr 05, 2018
-
-
Carl Lerche authored
Replaces homegrown Arc with std Arc Is this safer? Unknown. At least we don't have to maintain an arc implementation anymore. This will also make it easier to filter out tsan false positives. Also split task/mod.rs into multiple files.
-
- Apr 04, 2018
-
-
Carl Lerche authored
-
Carl Lerche authored
-
David authored
-
Igor Gnatenko authored
-
Leandro Pacheco authored
-
Roman authored
-
Carl Lerche authored
* Switch worker lifecycle to an enum * Move some files around * Rename State -> PoolState
-
- Apr 02, 2018
-
-
Kam Y. Tse authored
-
Roman authored
-
laizy authored
-
Roman authored
-
Daniel Griffen authored
-
- Apr 01, 2018
-
-
Roman authored
-
- Mar 30, 2018
-