diff --git a/lib/Forking/Fork.php b/lib/Forking/Fork.php
index 7085abb..bc554ce 100644
--- a/lib/Forking/Fork.php
+++ b/lib/Forking/Fork.php
@@ -2,19 +2,11 @@
 
 namespace Amp\Parallel\Forking;
 
-use function Amp\call;
 use Amp\{ Coroutine, Loop, Promise };
-use Amp\Parallel\{
-    ContextException,
-    ChannelException,
-    Process,
-    SerializationException,
-    StatusError,
-    Strand,
-    SynchronizationError
-};
-use Amp\Parallel\Sync\{ Channel, ChannelledSocket };
+use Amp\Parallel\{ ContextException, Process, StatusError, Strand, SynchronizationError };
+use Amp\Parallel\Sync\{ Channel, ChannelException, ChannelledSocket, SerializationException };
 use Amp\Parallel\Sync\Internal\{ ExitFailure, ExitResult, ExitSuccess };
+use function Amp\call;
 
 /**
  * Implements a UNIX-compatible context using forked processes.
diff --git a/lib/Process/ChannelledProcess.php b/lib/Process/ChannelledProcess.php
index e4f3c6e..afa4516 100644
--- a/lib/Process/ChannelledProcess.php
+++ b/lib/Process/ChannelledProcess.php
@@ -5,14 +5,13 @@ namespace Amp\Parallel\Process;
 use function Amp\call;
 use Amp\{ Coroutine, Promise };
 use Amp\Parallel\{
-    ChannelException,
     ContextException,
     Process as ProcessContext,
     StatusError,
     Strand,
     SynchronizationError
 };
-use Amp\Parallel\Sync\{ ChannelledSocket, Internal\ExitResult };
+use Amp\Parallel\Sync\{ ChannelException, ChannelledSocket, Internal\ExitResult };
 use Amp\Process\Process;
 
 class ChannelledProcess implements ProcessContext, Strand {
diff --git a/lib/ChannelException.php b/lib/Sync/ChannelException.php
similarity index 86%
rename from lib/ChannelException.php
rename to lib/Sync/ChannelException.php
index c4f0f35..0c61d48 100644
--- a/lib/ChannelException.php
+++ b/lib/Sync/ChannelException.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Sync;
 
 class ChannelException extends \Exception {
     public function __construct(string $message, \Throwable $previous = null) {
diff --git a/lib/Sync/ChannelledSocket.php b/lib/Sync/ChannelledSocket.php
index 6f8bb90..68abd8d 100644
--- a/lib/Sync/ChannelledSocket.php
+++ b/lib/Sync/ChannelledSocket.php
@@ -3,7 +3,6 @@
 namespace Amp\Parallel\Sync;
 
 use Amp\{ Deferred, Failure, Loop, Promise, Success };
-use Amp\Parallel\{ ChannelException, SerializationException };
 
 class ChannelledSocket implements Channel {
     const HEADER_LENGTH = 5;
diff --git a/lib/Sync/ChannelledStream.php b/lib/Sync/ChannelledStream.php
index 9a0659d..0ed456c 100644
--- a/lib/Sync/ChannelledStream.php
+++ b/lib/Sync/ChannelledStream.php
@@ -3,10 +3,7 @@
 namespace Amp\Parallel\Sync;
 
 use Amp\{ Coroutine, Promise };
-use Amp\ByteStream\{
-    InputStream, OutputStream, Parser, ReadableStream, StreamException, WritableStream
-};
-use Amp\Parallel\{ ChannelException, SerializationException };
+use Amp\ByteStream\{ InputStream, OutputStream, Parser, StreamException };
 
 /**
  * An asynchronous channel for sending data between threads and processes.
@@ -57,8 +54,8 @@ class ChannelledStream implements Channel {
      *
      * @return \Generator
      *
-     * @throws \Amp\Parallel\ChannelException
-     * @throws \Amp\Parallel\SerializationException
+     * @throws \Amp\Parallel\Sync\ChannelException
+     * @throws \Amp\Parallel\Sync\SerializationException
      */
     private static function parser(\SplQueue $queue, callable $errorHandler): \Generator {
         while (true) {
diff --git a/lib/Sync/Lock.php b/lib/Sync/Lock.php
index 549e282..9f3748e 100644
--- a/lib/Sync/Lock.php
+++ b/lib/Sync/Lock.php
@@ -2,8 +2,6 @@
 
 namespace Amp\Parallel\Sync;
 
-use Amp\Parallel\LockAlreadyReleasedError;
-
 /**
  * A handle on an acquired lock from a synchronization object.
  *
diff --git a/lib/LockAlreadyReleasedError.php b/lib/Sync/LockAlreadyReleasedError.php
similarity index 66%
rename from lib/LockAlreadyReleasedError.php
rename to lib/Sync/LockAlreadyReleasedError.php
index 72de1d6..8e20c77 100644
--- a/lib/LockAlreadyReleasedError.php
+++ b/lib/Sync/LockAlreadyReleasedError.php
@@ -1,5 +1,5 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Sync;
 
 class LockAlreadyReleasedError extends \Error {}
diff --git a/lib/MutexException.php b/lib/Sync/MutexException.php
similarity index 63%
rename from lib/MutexException.php
rename to lib/Sync/MutexException.php
index fdade9d..dd4559f 100644
--- a/lib/MutexException.php
+++ b/lib/Sync/MutexException.php
@@ -1,5 +1,5 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Sync;
 
 class MutexException extends \Exception {}
diff --git a/lib/Sync/PosixSemaphore.php b/lib/Sync/PosixSemaphore.php
index 7b8ba17..272f21a 100644
--- a/lib/Sync/PosixSemaphore.php
+++ b/lib/Sync/PosixSemaphore.php
@@ -4,7 +4,6 @@ namespace Amp\Parallel\Sync;
 
 use Amp\Coroutine;
 use Amp\Delayed;
-use Amp\Parallel\SemaphoreException;
 use Amp\Promise;
 
 /**
diff --git a/lib/SemaphoreException.php b/lib/Sync/SemaphoreException.php
similarity index 65%
rename from lib/SemaphoreException.php
rename to lib/Sync/SemaphoreException.php
index b3469cf..767610d 100644
--- a/lib/SemaphoreException.php
+++ b/lib/Sync/SemaphoreException.php
@@ -1,5 +1,5 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Sync;
 
 class SemaphoreException extends \Exception {}
diff --git a/lib/SerializationException.php b/lib/Sync/SerializationException.php
similarity index 69%
rename from lib/SerializationException.php
rename to lib/Sync/SerializationException.php
index eac5bdb..e5c341f 100644
--- a/lib/SerializationException.php
+++ b/lib/Sync/SerializationException.php
@@ -1,5 +1,5 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Sync;
 
 class SerializationException extends ChannelException {}
diff --git a/lib/SharedMemoryException.php b/lib/Sync/SharedMemoryException.php
similarity index 66%
rename from lib/SharedMemoryException.php
rename to lib/Sync/SharedMemoryException.php
index e203869..22179ac 100644
--- a/lib/SharedMemoryException.php
+++ b/lib/Sync/SharedMemoryException.php
@@ -1,5 +1,5 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Sync;
 
 class SharedMemoryException extends \Exception {}
diff --git a/lib/Sync/SharedMemoryParcel.php b/lib/Sync/SharedMemoryParcel.php
index c8f06dc..b265064 100644
--- a/lib/Sync/SharedMemoryParcel.php
+++ b/lib/Sync/SharedMemoryParcel.php
@@ -3,7 +3,6 @@
 namespace Amp\Parallel\Sync;
 
 use Amp\{ Coroutine, Promise };
-use Amp\Parallel\SharedMemoryException;
 
 /**
  * A container object for sharing a value across contexts.
diff --git a/lib/Threading/Internal/Thread.php b/lib/Threading/Internal/Thread.php
index 188a4c6..8e7e839 100644
--- a/lib/Threading/Internal/Thread.php
+++ b/lib/Threading/Internal/Thread.php
@@ -3,8 +3,14 @@
 namespace Amp\Parallel\Threading\Internal;
 
 use Amp\{ Coroutine, Loop, Promise };
-use Amp\Parallel\{ ChannelException, SerializationException };
-use Amp\Parallel\Sync\{ Channel, ChannelledSocket, Internal\ExitFailure, Internal\ExitSuccess };
+use Amp\Parallel\Sync\{
+    Channel,
+    ChannelException,
+    ChannelledSocket,
+    Internal\ExitFailure,
+    Internal\ExitSuccess,
+    SerializationException
+};
 
 /**
  * An internal thread that executes a given function concurrently.
diff --git a/lib/Threading/Thread.php b/lib/Threading/Thread.php
index c7ebfe4..fa797c8 100644
--- a/lib/Threading/Thread.php
+++ b/lib/Threading/Thread.php
@@ -4,8 +4,8 @@ namespace Amp\Parallel\Threading;
 
 use function Amp\call;
 use Amp\{ Coroutine, Loop, Promise };
-use Amp\Parallel\{ ChannelException, ContextException, StatusError, SynchronizationError, Strand };
-use Amp\Parallel\Sync\{ ChannelledSocket, Internal\ExitResult };
+use Amp\Parallel\{ ContextException, StatusError, SynchronizationError, Strand };
+use Amp\Parallel\Sync\{ ChannelException, ChannelledSocket, Internal\ExitResult };
 
 /**
  * Implements an execution context using native multi-threading.
diff --git a/lib/Worker/AbstractWorker.php b/lib/Worker/AbstractWorker.php
index 1c96399..7aaa4a7 100644
--- a/lib/Worker/AbstractWorker.php
+++ b/lib/Worker/AbstractWorker.php
@@ -3,7 +3,7 @@
 namespace Amp\Parallel\Worker;
 
 use Amp\{ Coroutine, Deferred, Promise };
-use Amp\Parallel\{ StatusError, Strand, WorkerException} ;
+use Amp\Parallel\{ StatusError, Strand } ;
 use Amp\Parallel\Worker\Internal\{ Job, TaskResult };
 
 /**
@@ -100,8 +100,9 @@ abstract class AbstractWorker implements Worker {
      *
      * @return \Generator
      * @throws \Amp\Parallel\StatusError
-     * @throws \Amp\Parallel\TaskException
-     * @throws \Amp\Parallel\WorkerException
+     * @throws \Amp\Parallel\Worker\TaskException
+     * @throws \Amp\Parallel\Worker\TaskError
+     * @throws \Amp\Parallel\Worker\WorkerException
      */
     private function doEnqueue(Task $task): \Generator {
         if (empty($this->jobQueue)) {
diff --git a/lib/Worker/Internal/TaskFailure.php b/lib/Worker/Internal/TaskFailure.php
index 4fb0770..3ad381b 100644
--- a/lib/Worker/Internal/TaskFailure.php
+++ b/lib/Worker/Internal/TaskFailure.php
@@ -3,13 +3,20 @@
 namespace Amp\Parallel\Worker\Internal;
 
 use Amp\Failure;
-use Amp\Parallel\TaskException;
+use Amp\Parallel\Worker\TaskError;
+use Amp\Parallel\Worker\TaskException;
 use Amp\Promise;
 
 class TaskFailure extends TaskResult {
+    const PARENT_EXCEPTION = 0;
+    const PARENT_ERROR = 1;
+
     /** @var string */
     private $type;
 
+    /** @var int */
+    private $parent;
+
     /** @var string */
     private $message;
 
@@ -22,17 +29,32 @@ class TaskFailure extends TaskResult {
     public function __construct(string $id, \Throwable $exception) {
         parent::__construct($id);
         $this->type = \get_class($exception);
+        $this->parent = $exception instanceof \Error ? self::PARENT_ERROR : self::PARENT_EXCEPTION;
         $this->message = $exception->getMessage();
         $this->code = $exception->getCode();
         $this->trace = $exception->getTraceAsString();
     }
     
     public function promise(): Promise {
-        return new Failure(new TaskException(
-            $this->type,
-            sprintf('Uncaught exception in worker of type "%s" with message "%s"', $this->type, $this->message),
-            $this->code,
-            $this->trace
-        ));
+        switch ($this->parent) {
+            case self::PARENT_ERROR:
+                $exception = new TaskError(
+                    $this->type,
+                    sprintf('Uncaught Error in worker of type "%s" with message "%s"', $this->type, $this->message),
+                    $this->code,
+                    $this->trace
+                );
+                break;
+
+            default:
+                $exception = new TaskException(
+                    $this->type,
+                    sprintf('Uncaught Exception in worker of type "%s" with message "%s"', $this->type, $this->message),
+                    $this->code,
+                    $this->trace
+                );
+        }
+
+        return new Failure($exception);
     }
 }
\ No newline at end of file
diff --git a/lib/Worker/TaskError.php b/lib/Worker/TaskError.php
new file mode 100644
index 0000000..14d4fdb
--- /dev/null
+++ b/lib/Worker/TaskError.php
@@ -0,0 +1,41 @@
+<?php
+
+namespace Amp\Parallel\Worker;
+
+class TaskError extends \Error {
+    /** @var string Class name of error thrown from task. */
+    private $name;
+
+    /** @var string Stack trace of the error thrown from task. */
+    private $trace;
+
+    /**
+     * @param string $name    The exception class name.
+     * @param string $message The panic message.
+     * @param int    $code    The panic code.
+     * @param string $trace   The panic stack trace.
+     */
+    public function __construct(string $name, string $message = '', int $code = 0, string $trace = '') {
+        parent::__construct($message, $code);
+        $this->name = $name;
+        $this->trace = $trace;
+    }
+    
+    /**
+     * Returns the class name of the error thrown from the task.
+     *
+     * @return string
+     */
+    public function getName(): string {
+        return $this->name;
+    }
+    
+    /**
+     * Gets the stack trace at the point the error was thrown in the task.
+     *
+     * @return string
+     */
+    public function getWorkerTrace(): string {
+        return $this->trace;
+    }
+}
diff --git a/lib/TaskException.php b/lib/Worker/TaskException.php
similarity index 94%
rename from lib/TaskException.php
rename to lib/Worker/TaskException.php
index 2d7a223..75fe7d2 100644
--- a/lib/TaskException.php
+++ b/lib/Worker/TaskException.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Worker;
 
 class TaskException extends \Exception {
     /** @var string Class name of exception thrown from task. */
@@ -10,8 +10,6 @@ class TaskException extends \Exception {
     private $trace;
 
     /**
-     * Creates a new panic error.
-     *
      * @param string $name    The exception class name.
      * @param string $message The panic message.
      * @param int    $code    The panic code.
diff --git a/lib/WorkerException.php b/lib/Worker/WorkerException.php
similarity index 89%
rename from lib/WorkerException.php
rename to lib/Worker/WorkerException.php
index 36db35f..1ddf291 100644
--- a/lib/WorkerException.php
+++ b/lib/Worker/WorkerException.php
@@ -1,6 +1,6 @@
 <?php
 
-namespace Amp\Parallel;
+namespace Amp\Parallel\Worker;
 
 class WorkerException extends \Exception {
     /**
diff --git a/test/Sync/ChannelledSocketTest.php b/test/Sync/ChannelledSocketTest.php
index abd8cd3..cc3606c 100644
--- a/test/Sync/ChannelledSocketTest.php
+++ b/test/Sync/ChannelledSocketTest.php
@@ -59,7 +59,7 @@ class ChannelledSocketTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testInvalidDataReceived() {
         Loop::run(function () {
@@ -75,7 +75,7 @@ class ChannelledSocketTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testSendUnserializableData() {
         Loop::run(function () {
@@ -92,7 +92,7 @@ class ChannelledSocketTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testSendAfterClose() {
         Loop::run(function () {
@@ -107,7 +107,7 @@ class ChannelledSocketTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testReceiveAfterClose() {
         Loop::run(function () {
diff --git a/test/Sync/ChannelledStreamTest.php b/test/Sync/ChannelledStreamTest.php
index 89da709..4213729 100644
--- a/test/Sync/ChannelledStreamTest.php
+++ b/test/Sync/ChannelledStreamTest.php
@@ -78,7 +78,7 @@ class ChannelledStreamTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testInvalidDataReceived() {
         Loop::run(function () {
@@ -95,7 +95,7 @@ class ChannelledStreamTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testSendUnserializableData() {
         Loop::run(function () {
@@ -112,7 +112,7 @@ class ChannelledStreamTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testSendAfterClose() {
         Loop::run(function () {
@@ -134,7 +134,7 @@ class ChannelledStreamTest extends TestCase {
 
     /**
      * @depends testSendReceive
-     * @expectedException \Amp\Parallel\ChannelException
+     * @expectedException \Amp\Parallel\Sync\ChannelException
      */
     public function testReceiveAfterClose() {
         Loop::run(function () {
diff --git a/test/Sync/LockTest.php b/test/Sync/LockTest.php
index 2b10864..340daee 100644
--- a/test/Sync/LockTest.php
+++ b/test/Sync/LockTest.php
@@ -19,7 +19,7 @@ class LockTest extends TestCase {
     }
 
     /**
-     * @expectedException \Amp\Parallel\LockAlreadyReleasedError
+     * @expectedException \Amp\Parallel\Sync\LockAlreadyReleasedError
      */
     public function testThrowsOnMultiRelease() {
         $lock = new Lock($this->createCallback(1));
diff --git a/test/Sync/SharedMemoryParcelTest.php b/test/Sync/SharedMemoryParcelTest.php
index 3125d15..744962a 100644
--- a/test/Sync/SharedMemoryParcelTest.php
+++ b/test/Sync/SharedMemoryParcelTest.php
@@ -35,7 +35,7 @@ class SharedMemoryParcelTest extends AbstractParcelTest {
     }
 
     /**
-     * @expectedException \Amp\Parallel\SharedMemoryException
+     * @expectedException \Amp\Parallel\Sync\SharedMemoryException
      */
     public function testUnwrapThrowsErrorIfFreed() {
         $object = new SharedMemoryParcel(new \stdClass());