@@ -0,0 +1,961 @@
+package com.noveogroup.android.task;%0A%0Aimport junit.framework.Assert;%0Aimport org.junit.Test;%0A%0Aimport java.util.concurrent.Executors;%0A%0Apublic class TaskTest %7B%0A%0A    private TaskExecutor createTaskExecutor() %7B%0A        return new SimpleTaskExecutor(Executors.newFixedThreadPool(3)) %7B%0A            @Override%0A            protected TaskEnvironment createTaskEnvironment(TaskHandler taskHandler) %7B%0A                return new SimpleTaskEnvironment(taskHandler);%0A            %7D%0A        %7D;%0A    %7D%0A%0A    @Test%0A    public void runTest() throws InterruptedException %7B%0A        final StringBuffer buffer = new StringBuffer();%0A%0A        TaskExecutor executor = createTaskExecutor();%0A        executor.execute(new Task() %7B%0A            @Override%0A            public void run(TaskEnvironment env) throws Throwable %7B%0A                buffer.append(%22Task::run%22);%0A            %7D%0A        %7D);%0A        Thread.sleep(Utils.DT);%0A%0A        Assert.assertEquals(%22Task::run%22, buffer.toString());%0A    %7D%0A%0A%7D%0A

create TaskTest