diff --git a/Cargo.toml b/Cargo.toml
index 63a607e2d..5a75e9ac6 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -70,11 +70,12 @@ actix-codec = "0.1.1"
 actix-service = "0.3.4"
 actix-utils = "0.3.4"
 actix-router = "0.1.0"
-actix-rt = "0.2.1"
+actix-rt = "0.2.2"
 actix-web-codegen = { path="actix-web-codegen" }
 actix-http = { path = "actix-http", features=["fail"] }
 actix-server = "0.4.1"
 actix-server-config = "0.1.0"
+actix-threadpool = "0.1.0"
 awc = { path = "awc", optional = true }
 
 bytes = "0.4"
diff --git a/src/error.rs b/src/error.rs
index f7610d509..984b46e08 100644
--- a/src/error.rs
+++ b/src/error.rs
@@ -37,11 +37,11 @@ pub enum BlockingError<E: fmt::Debug> {
 
 impl<E: fmt::Debug> ResponseError for BlockingError<E> {}
 
-impl<E: fmt::Debug> From<actix_rt::blocking::BlockingError<E>> for BlockingError<E> {
-    fn from(err: actix_rt::blocking::BlockingError<E>) -> Self {
+impl<E: fmt::Debug> From<actix_threadpool::BlockingError<E>> for BlockingError<E> {
+    fn from(err: actix_threadpool::BlockingError<E>) -> Self {
         match err {
-            actix_rt::blocking::BlockingError::Error(e) => BlockingError::Error(e),
-            actix_rt::blocking::BlockingError::Canceled => BlockingError::Canceled,
+            actix_threadpool::BlockingError::Error(e) => BlockingError::Error(e),
+            actix_threadpool::BlockingError::Canceled => BlockingError::Canceled,
         }
     }
 }
diff --git a/src/lib.rs b/src/lib.rs
index d3d66c616..ec5a9e6a9 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -162,7 +162,6 @@ pub mod dev {
 pub mod web {
     //! Various types
     use actix_http::{http::Method, Response};
-    use actix_rt::blocking;
     use futures::{Future, IntoFuture};
 
     pub use actix_http::Response as HttpResponse;
@@ -339,7 +338,7 @@ pub mod web {
         I: Send + 'static,
         E: Send + std::fmt::Debug + 'static,
     {
-        blocking::run(f).from_err()
+        actix_threadpool::run(f).from_err()
     }
 
     use actix_service::{fn_transform, Service, Transform};