Upgrade crossbeam

Author: Seulgi Kim

Cargo.lock

@@ -10,6 +10,6 @@ authors = ["Parity Technologies <[email protected]>", "CodeChain Team <codechain@k
 codechain-limited-table = { path = "../limited_table" }
 codechain-logger = { path = "../logger" }
 mio = "0.6.16"
-crossbeam = "0.3"
+crossbeam = "0.5.0"
 parking_lot = "0.6.0"
 log = "0.4.6"

util/io/Cargo.toml

@@ -15,7 +15,7 @@
 // along with Parity.  If not, see <http://www.gnu.org/licenses/>.
 
 use climited_table::LimitedTable;
-use crossbeam::sync::chase_lev;
+use crossbeam::deque;
 use mio::deprecated::{EventLoop, EventLoopBuilder, Handler, Sender};
 use mio::timer::Timeout;
 use mio::*;
@@ -196,7 +196,7 @@ where
     timers: Arc<RwLock<HashMap<HandlerId, UserTimer>>>,
     handlers: Arc<HandlersType<Message>>,
     workers: Vec<Worker>,
-    worker_channel: chase_lev::Worker<Work<Message>>,
+    worker_channel: deque::Worker<Work<Message>>,
     work_ready: Arc<SCondvar>,
 }
 
@@ -210,7 +210,7 @@ where
         handlers: Arc<HandlersType<Message>>,
         name: &str,
     ) -> Result<(), IoError> {
-        let (worker, stealer) = chase_lev::deque();
+        let (worker, stealer) = deque::lifo();
         let num_workers = 4;
         let work_ready_mutex = Arc::new(SMutex::new(()));
         let work_ready = Arc::new(SCondvar::new());

util/io/src/service.rs

@@ -14,7 +14,7 @@
 // You should have received a copy of the GNU General Public License
 // along with Parity.  If not, see <http://www.gnu.org/licenses/>.
 
-use crossbeam::sync::chase_lev;
+use crossbeam::deque;
 use service::{HandlerId, IoChannel, IoContext};
 use std::cell::Cell;
 use std::sync::atomic::{AtomicBool, Ordering as AtomicOrdering};
@@ -61,7 +61,7 @@ impl Worker {
     /// Creates a new worker instance.
     pub fn new<Message>(
         index: usize,
-        stealer: chase_lev::Stealer<Work<Message>>,
+        stealer: deque::Stealer<Work<Message>>,
         channel: IoChannel<Message>,
         wait: Arc<SCondvar>,
         wait_mutex: Arc<SMutex<()>>,
@@ -90,7 +90,7 @@ impl Worker {
     }
 
     fn work_loop<Message>(
-        stealer: &chase_lev::Stealer<Work<Message>>,
+        stealer: &deque::Stealer<Work<Message>>,
         channel: &IoChannel<Message>,
         wait: &SCondvar,
         wait_mutex: &SMutex<()>,
@@ -108,7 +108,7 @@ impl Worker {
 
             while !deleting.load(AtomicOrdering::Acquire) {
                 match stealer.steal() {
-                    chase_lev::Steal::Data(work) => Worker::do_work(work, channel.clone()),
+                    deque::Steal::Data(work) => Worker::do_work(work, channel.clone()),
                     _ => break,
                 }
             }