diff --git a/README.md b/README.md
index 33bf32a..3a1f08e 100644
--- a/README.md
+++ b/README.md
@@ -14,6 +14,10 @@
         ...
     })
     ```
+- 增加取消压缩方法
+    ```
+    VideoCompress.compressCancel();
+    ```
 # 本分支集成方式
 
 Step 1. Add the JitPack repository to your build file
diff --git a/app/src/main/java/com/vincent/videocompress/MainActivity.java b/app/src/main/java/com/vincent/videocompress/MainActivity.java
index dc82aa1..5c97885 100644
--- a/app/src/main/java/com/vincent/videocompress/MainActivity.java
+++ b/app/src/main/java/com/vincent/videocompress/MainActivity.java
@@ -3,6 +3,7 @@
 import android.annotation.TargetApi;
 import android.content.Intent;
 import android.content.res.Configuration;
+import android.os.AsyncTask;
 import android.os.Build;
 import android.os.Environment;
 import android.os.Bundle;
@@ -16,6 +17,7 @@
 
 import com.vincent.videocompressor.CompressConfig;
 import com.vincent.videocompressor.VideoCompress;
+import com.vincent.videocompressor.VideoController;
 
 import java.io.File;
 import java.net.URISyntaxException;
@@ -49,113 +51,119 @@ protected void onPostCreate(@Nullable Bundle savedInstanceState) {
 
     private void initView() {
         Button btn_select = (Button) findViewById(R.id.btn_select);
-        btn_select.setOnClickListener(new View.OnClickListener() {
-            @Override
-            public void onClick(View view) {
-                Intent intent = new Intent();
-                /* 开启Pictures画面Type设定为image */
-                //intent.setType("video/*;image/*");
-                //intent.setType("audio/*"); //选择音频
-                intent.setType("video/*"); //选择视频 （mp4 3gp 是android支持的视频格式）
-                intent.setAction(Intent.ACTION_GET_CONTENT);
-                startActivityForResult(intent, REQUEST_FOR_VIDEO_FILE);
-            }
+        btn_select.setOnClickListener(view -> {
+            Intent intent = new Intent();
+            /* 开启Pictures画面Type设定为image */
+            //intent.setType("video/*;image/*");
+            //intent.setType("audio/*"); //选择音频
+            intent.setType("video/*"); //选择视频 （mp4 3gp 是android支持的视频格式）
+            intent.setAction(Intent.ACTION_GET_CONTENT);
+            startActivityForResult(intent, REQUEST_FOR_VIDEO_FILE);
         });
 
         Button btn_compress = (Button) findViewById(R.id.btn_compress);
-        btn_compress.setOnClickListener(new View.OnClickListener() {
-            @Override
-            public void onClick(View view) {
-                String destPath = tv_output.getText().toString() + File.separator + "VID_" + new SimpleDateFormat("yyyyMMdd_HHmmss", getLocale()).format(new Date()) + ".mp4";
-                VideoCompress.compressVideoLow(tv_input.getText().toString(), destPath, new VideoCompress.CompressListener() {
-                    @Override
-                    public void onStart() {
-                        tv_indicator.setText("Compressing..." + "\n"
-                                + "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
-                        pb_compress.setVisibility(View.VISIBLE);
-                        startTime = System.currentTimeMillis();
-                        Util.writeFile(MainActivity.this, "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
-                    }
-
-                    @Override
-                    public void onSuccess() {
-                        String previous = tv_indicator.getText().toString();
-                        tv_indicator.setText(previous + "\n"
-                                + "Compress Success!" + "\n"
-                                + "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
-                        pb_compress.setVisibility(View.INVISIBLE);
-                        endTime = System.currentTimeMillis();
-                        Util.writeFile(MainActivity.this, "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
-                        Util.writeFile(MainActivity.this, "Total: " + ((endTime - startTime) / 1000) + "s" + "\n");
-                        Util.writeFile(MainActivity.this);
-                    }
-
-                    @Override
-                    public void onFail() {
-                        tv_indicator.setText("Compress Failed!");
-                        pb_compress.setVisibility(View.INVISIBLE);
-                        endTime = System.currentTimeMillis();
-                        Util.writeFile(MainActivity.this, "Failed Compress!!!" + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
-                    }
-
-                    @Override
-                    public void onProgress(float percent) {
-                        tv_progress.setText(String.valueOf(percent) + "%");
-                    }
-                });
-            }
+        btn_compress.setOnClickListener(view -> {
+            String destPath = tv_output.getText().toString() + File.separator + "VID_" + new SimpleDateFormat("yyyyMMdd_HHmmss", getLocale()).format(new Date()) + ".mp4";
+            VideoCompress.compressVideoLow(tv_input.getText().toString(), destPath, new VideoCompress.CompressListener() {
+                @Override
+                public void onCancel() {
+                    pb_compress.setVisibility(View.INVISIBLE);
+                    tv_indicator.setText("Compress Cancel!");
+                }
+
+                @Override
+                public void onStart() {
+                    tv_indicator.setText("Compressing..." + "\n"
+                            + "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
+                    pb_compress.setVisibility(View.VISIBLE);
+                    startTime = System.currentTimeMillis();
+                    Util.writeFile(MainActivity.this, "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
+                }
+
+                @Override
+                public void onSuccess() {
+                    String previous = tv_indicator.getText().toString();
+                    tv_indicator.setText(previous + "\n"
+                            + "Compress Success!" + "\n"
+                            + "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
+                    pb_compress.setVisibility(View.INVISIBLE);
+                    endTime = System.currentTimeMillis();
+                    Util.writeFile(MainActivity.this, "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
+                    Util.writeFile(MainActivity.this, "Total: " + ((endTime - startTime) / 1000) + "s" + "\n");
+                    Util.writeFile(MainActivity.this);
+                }
+
+                @Override
+                public void onFail() {
+                    tv_indicator.setText("Compress Failed!");
+                    pb_compress.setVisibility(View.INVISIBLE);
+                    endTime = System.currentTimeMillis();
+                    Util.writeFile(MainActivity.this, "Failed Compress!!!" + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
+                }
+
+                @Override
+                public void onProgress(float percent) {
+                    tv_progress.setText(String.valueOf(percent) + "%");
+                }
+            });
         });
 
-        findViewById(R.id.btn_custom).setOnClickListener(new View.OnClickListener() {
-
-            @Override
-            public void onClick(View v) {
-                String srcPath = tv_input.getText().toString();
-                String destPath = tv_output.getText().toString() + File.separator + "VID_" + new SimpleDateFormat("yyyyMMdd_HHmmss", getLocale()).format(new Date()) + ".mp4";
-                CompressConfig config = new CompressConfig
-                        .Builder()
-                        .width(1280)
-                        .height(720)
-                        .bitrate(1280 * 720 * 2)
-                        .frame(24)
-                        .build();
-                VideoCompress.compressVideoCustom(srcPath, destPath, config, new VideoCompress.CompressListener() {
-                    @Override
-                    public void onStart() {
-                        tv_indicator.setText("Compressing..." + "\n"
-                                + "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
-                        pb_compress.setVisibility(View.VISIBLE);
-                        startTime = System.currentTimeMillis();
-                        Util.writeFile(MainActivity.this, "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
-                    }
-
-                    @Override
-                    public void onSuccess() {
-                        String previous = tv_indicator.getText().toString();
-                        tv_indicator.setText(previous + "\n"
-                                + "Compress Success!" + "\n"
-                                + "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
-                        pb_compress.setVisibility(View.INVISIBLE);
-                        endTime = System.currentTimeMillis();
-                        Util.writeFile(MainActivity.this, "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
-                        Util.writeFile(MainActivity.this, "Total: " + ((endTime - startTime) / 1000) + "s" + "\n");
-                        Util.writeFile(MainActivity.this);
-                    }
-
-                    @Override
-                    public void onFail() {
-                        tv_indicator.setText("Compress Failed!");
-                        pb_compress.setVisibility(View.INVISIBLE);
-                        endTime = System.currentTimeMillis();
-                        Util.writeFile(MainActivity.this, "Failed Compress!!!" + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
-                    }
-
-                    @Override
-                    public void onProgress(float percent) {
-                        tv_progress.setText(String.valueOf(percent) + "%");
-                    }
-                });
-            }
+        findViewById(R.id.btn_custom).setOnClickListener(v -> {
+            String srcPath = tv_input.getText().toString();
+            String destPath = tv_output.getText().toString() + File.separator + "VID_" + new SimpleDateFormat("yyyyMMdd_HHmmss", getLocale()).format(new Date()) + ".mp4";
+            CompressConfig config = new CompressConfig
+                    .Builder()
+                    .width(1280)
+                    .height(720)
+                    .bitrate(1280 * 720 * 2)
+                    .frame(24)
+                    .build();
+            VideoCompress.compressVideoCustom(srcPath, destPath, config, new VideoCompress.CompressListener() {
+                @Override
+                public void onStart() {
+                    tv_indicator.setText("Compressing..." + "\n"
+                            + "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
+                    pb_compress.setVisibility(View.VISIBLE);
+                    startTime = System.currentTimeMillis();
+                    Util.writeFile(MainActivity.this, "Start at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
+                }
+
+                @Override
+                public void onSuccess() {
+                    String previous = tv_indicator.getText().toString();
+                    tv_indicator.setText(previous + "\n"
+                            + "Compress Success!" + "\n"
+                            + "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
+                    pb_compress.setVisibility(View.INVISIBLE);
+                    endTime = System.currentTimeMillis();
+                    Util.writeFile(MainActivity.this, "End at: " + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()) + "\n");
+                    Util.writeFile(MainActivity.this, "Total: " + ((endTime - startTime) / 1000) + "s" + "\n");
+                    Util.writeFile(MainActivity.this);
+                }
+
+                @Override
+                public void onCancel() {
+                    pb_compress.setVisibility(View.INVISIBLE);
+                    tv_indicator.setText("Compress Cancel!");
+                }
+
+                @Override
+                public void onFail() {
+                    tv_indicator.setText("Compress Failed!");
+                    pb_compress.setVisibility(View.INVISIBLE);
+                    endTime = System.currentTimeMillis();
+                    Util.writeFile(MainActivity.this, "Failed Compress!!!" + new SimpleDateFormat("HH:mm:ss", getLocale()).format(new Date()));
+                }
+
+                @Override
+                public void onProgress(float percent) {
+                    tv_progress.setText(String.valueOf(percent) + "%");
+                }
+            });
+        });
+
+        findViewById(R.id.btn_cancel).setOnClickListener(v -> {
+            VideoCompress.compressCancel();
         });
 
         tv_input = (TextView) findViewById(R.id.tv_input);
diff --git a/app/src/main/res/layout/activity_main.xml b/app/src/main/res/layout/activity_main.xml
index 89164b5..e5123ad 100644
--- a/app/src/main/res/layout/activity_main.xml
+++ b/app/src/main/res/layout/activity_main.xml
@@ -19,6 +19,20 @@
             android:text="Select File"
             android:textAllCaps="false" />
 
+        <Button
+            android:id="@+id/btn_cancel"
+            android:layout_width="wrap_content"
+            android:layout_height="wrap_content"
+            android:text="Cancel Compress"
+            android:textAllCaps="false" />
+    </LinearLayout>
+
+    <LinearLayout
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:gravity="center_horizontal"
+        android:orientation="horizontal">
+
         <Button
             android:id="@+id/btn_compress"
             android:layout_width="wrap_content"
diff --git a/videocompressor/src/main/java/com/vincent/videocompressor/VideoCompress.java b/videocompressor/src/main/java/com/vincent/videocompressor/VideoCompress.java
index 5cf2747..e9f5ba0 100644
--- a/videocompressor/src/main/java/com/vincent/videocompressor/VideoCompress.java
+++ b/videocompressor/src/main/java/com/vincent/videocompressor/VideoCompress.java
@@ -35,7 +35,11 @@ public static VideoCompressTask compressVideoCustom(String srcPath, String destP
         return task;
     }
 
-    private static class VideoCompressTask extends AsyncTask<String, Float, Boolean> {
+    public static void compressCancel() {
+        VideoController.getInstance().cancelVideoConvert();
+    }
+
+    private static class VideoCompressTask extends AsyncTask<String, Float, Integer> {
         private CompressListener mListener;
         private int mQuality;
         private CompressConfig mConfig;
@@ -60,13 +64,8 @@ protected void onPreExecute() {
         }
 
         @Override
-        protected Boolean doInBackground(String... paths) {
-            return VideoController.getInstance().convertVideo(paths[0], paths[1], mQuality, mConfig, new VideoController.CompressProgressListener() {
-                @Override
-                public void onProgress(float percent) {
-                    publishProgress(percent);
-                }
-            });
+        protected Integer doInBackground(String... paths) {
+            return VideoController.getInstance().convertVideo(paths[0], paths[1], mQuality, mConfig, percent -> publishProgress(percent));
         }
 
         @Override
@@ -78,13 +77,19 @@ protected void onProgressUpdate(Float... percent) {
         }
 
         @Override
-        protected void onPostExecute(Boolean result) {
+        protected void onPostExecute(Integer result) {
             super.onPostExecute(result);
             if (mListener != null) {
-                if (result) {
-                    mListener.onSuccess();
-                } else {
-                    mListener.onFail();
+                switch (result) {
+                    case VideoController.COMPRESS_TYPE_CANCEL:
+                        mListener.onCancel();
+                        break;
+                    case VideoController.COMPRESS_TYPE_SUCCESS:
+                        mListener.onSuccess();
+                        break;
+                    case VideoController.COMPRESS_TYPE_FAIL:
+                        mListener.onFail();
+                        break;
                 }
             }
         }
@@ -95,6 +100,8 @@ public interface CompressListener {
 
         void onSuccess();
 
+        void onCancel();
+
         void onFail();
 
         void onProgress(float percent);
diff --git a/videocompressor/src/main/java/com/vincent/videocompressor/VideoController.java b/videocompressor/src/main/java/com/vincent/videocompressor/VideoController.java
index beab190..d56062b 100644
--- a/videocompressor/src/main/java/com/vincent/videocompressor/VideoController.java
+++ b/videocompressor/src/main/java/com/vincent/videocompressor/VideoController.java
@@ -17,12 +17,15 @@
 import java.io.IOException;
 import java.nio.ByteBuffer;
 import java.nio.channels.FileChannel;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.Locale;
 
 @SuppressLint("NewApi")
 public class VideoController {
+    static final String ERROR_CANCEL = "canceled conversion";
+
+    static final int COMPRESS_TYPE_SUCCESS = 0;
+    static final int COMPRESS_TYPE_CANCEL = 1;
+    static final int COMPRESS_TYPE_FAIL = 2;
+
     static final int COMPRESS_QUALITY_HIGH = 1;
     static final int COMPRESS_QUALITY_MEDIUM = 2;
     static final int COMPRESS_QUALITY_LOW = 3;
@@ -40,6 +43,8 @@ public class VideoController {
     private final static int PROCESSOR_TYPE_TI = 5;
     private static volatile VideoController Instance = null;
     private boolean videoConvertFirstWrite = true;
+    private final Object videoConvertSync = new Object();
+    private boolean cancelCurrentVideoConversion = false;
 
     interface CompressProgressListener {
         void onProgress(float percent);
@@ -242,6 +247,23 @@ private int selectTrack(MediaExtractor extractor, boolean audio) {
         return -5;
     }
 
+    private void checkConversionCanceled() {
+        boolean cancelConversion;
+        synchronized (videoConvertSync) {
+            cancelConversion = cancelCurrentVideoConversion;
+        }
+        if (cancelConversion) {
+            throw new RuntimeException(ERROR_CANCEL);
+        }
+    }
+
+    public void cancelVideoConvert() {
+        synchronized (videoConvertSync) {
+            cancelCurrentVideoConversion = true;
+        }
+    }
+
+
     /**
      * Perform the actual video compression. Processes the frames and does the magic
      *
@@ -250,7 +272,10 @@ private int selectTrack(MediaExtractor extractor, boolean audio) {
      * @return
      */
     @TargetApi(16)
-    public boolean convertVideo(final String sourcePath, String destinationPath, int quality, CompressConfig config, CompressProgressListener listener) {
+    public int convertVideo(final String sourcePath, String destinationPath, int quality, CompressConfig config, CompressProgressListener listener) {
+        synchronized (videoConvertSync) {
+            cancelCurrentVideoConversion = false;
+        }
         if (quality == COMPRESS_QUALITY_CUSTOM && config == null) {
             throw new RuntimeException("CompressConfig 不能为空!");
         }
@@ -334,7 +359,7 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
         File inputFile = new File(path);
         if (!inputFile.canRead()) {
             didWriteData(true, true);
-            return false;
+            return COMPRESS_TYPE_FAIL;
         }
 
         videoConvertFirstWrite = true;
@@ -342,6 +367,7 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
         long videoStartTime = startTime;
 
         long time = System.currentTimeMillis();
+        boolean cancel = false;
 
         if (resultWidth != 0 && resultHeight != 0) {
             MP4Builder mediaMuxer = null;
@@ -484,8 +510,9 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
                                     encoderInputBuffers = encoder.getInputBuffers();
                                 }
                             }
-
+                            checkConversionCanceled();
                             while (!outputDone) {
+                                checkConversionCanceled();
                                 if (!inputDone) {
                                     boolean eof = false;
                                     int index = extractor.getSampleTrackIndex();
@@ -522,6 +549,7 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
                                 boolean decoderOutputAvailable = !decoderDone;
                                 boolean encoderOutputAvailable = true;
                                 while (decoderOutputAvailable || encoderOutputAvailable) {
+                                    checkConversionCanceled();
                                     int encoderStatus = encoder.dequeueOutputBuffer(info, TIMEOUT_USEC);
                                     if (encoderStatus == MediaCodec.INFO_TRY_AGAIN_LATER) {
                                         encoderOutputAvailable = false;
@@ -693,6 +721,7 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
                             encoder.stop();
                             encoder.release();
                         }
+                        checkConversionCanceled();
                     }
                 } else {
                     long videoTime = readAndWriteTrack(extractor, mediaMuxer, info, startTime, endTime, cacheFile, false);
@@ -705,6 +734,9 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
                 }
             } catch (Exception e) {
                 error = true;
+                if (ERROR_CANCEL.equals(e.getMessage())) {
+                    cancel = true;
+                }
                 Log.e("tmessages", e.getMessage());
             } finally {
                 if (extractor != null) {
@@ -721,7 +753,7 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
             }
         } else {
             didWriteData(true, true);
-            return false;
+            return COMPRESS_TYPE_FAIL;
         }
         didWriteData(true, error);
 
@@ -776,7 +808,12 @@ public boolean convertVideo(final String sourcePath, String destinationPath, int
         }*/
         // cacheFile.delete();
         // inputFile.delete();
-        return true;
+        if (cancel) {
+            cachedFile.delete();
+            return COMPRESS_TYPE_CANCEL;
+        } else {
+            return COMPRESS_TYPE_SUCCESS;
+        }
     }
 
     public static void copyFile(File src, File dst) throws IOException {