diff --git a/server/src/sys/entity_sync.rs b/server/src/sys/entity_sync.rs
index 964df88283..84fa0263e3 100644
--- a/server/src/sys/entity_sync.rs
+++ b/server/src/sys/entity_sync.rs
@@ -16,7 +16,8 @@ use common::{
 use common_ecs::{Job, Origin, Phase, System};
 use common_net::{msg::ServerGeneral, sync::CompSyncPackage};
 use itertools::Either;
-use specs::{Entities, Join, Read, ReadExpect, ReadStorage, Write, WriteStorage};
+use rayon::iter::ParallelIterator;
+use specs::{Entities, Join, ParJoin, Read, ReadExpect, ReadStorage, Write, WriteStorage};
 use vek::*;
 
 /// This system will send physics updates to the client
@@ -114,7 +115,7 @@ impl<'a> System<'a> for Sys {
                 &subscriptions,
                 &positions,
             )
-                .join()
+                .par_join()
                 .filter_map(|(client, entity, presence, subscription, pos)| {
                     if presence.is_some() && subscription.regions.contains(&key) {
                         Some((client, &subscription.regions, entity, *pos))
@@ -321,32 +322,36 @@ impl<'a> System<'a> for Sys {
         // TODO: Sync clients that don't have a position?
 
         // Sync inventories
-        for (inventory, update, client) in (&inventories, &inventory_updates, &clients).join() {
-            client.send_fallible(ServerGeneral::InventoryUpdate(
-                inventory.clone(),
-                update.event(),
-            ));
-        }
+        (&inventories, &inventory_updates, &clients)
+            .par_join()
+            .for_each(|(inventory, update, client)| {
+                client.send_fallible(ServerGeneral::InventoryUpdate(
+                    inventory.clone(),
+                    update.event(),
+                ));
+            });
 
         // Sync outcomes
-        for (presence, pos, client) in (presences.maybe(), positions.maybe(), &clients).join() {
-            let is_near = |o_pos: Vec3<f32>| {
-                pos.zip_with(presence, |pos, presence| {
-                    pos.0.xy().distance_squared(o_pos.xy())
-                        < (presence.view_distance as f32 * TerrainChunkSize::RECT_SIZE.x as f32)
-                            .powi(2)
-                })
-            };
+        (presences.maybe(), positions.maybe(), &clients)
+            .par_join()
+            .for_each(|(presence, pos, client)| {
+                let is_near = |o_pos: Vec3<f32>| {
+                    pos.zip_with(presence, |pos, presence| {
+                        pos.0.xy().distance_squared(o_pos.xy())
+                            < (presence.view_distance as f32 * TerrainChunkSize::RECT_SIZE.x as f32)
+                                .powi(2)
+                    })
+                };
 
-            let outcomes = outcomes
-                .iter()
-                .filter(|o| o.get_pos().and_then(&is_near).unwrap_or(true))
-                .cloned()
-                .collect::<Vec<_>>();
-            if !outcomes.is_empty() {
-                client.send_fallible(ServerGeneral::Outcomes(outcomes));
-            }
-        }
+                let outcomes = outcomes
+                    .iter()
+                    .filter(|o| o.get_pos().and_then(&is_near).unwrap_or(true))
+                    .cloned()
+                    .collect::<Vec<_>>();
+                if !outcomes.is_empty() {
+                    client.send_fallible(ServerGeneral::Outcomes(outcomes));
+                }
+            });
         outcomes.clear();
 
         // Remove all force flags.