Потоки, семафор в задаче про корабли

import java.util.ArrayList;
import java.util.concurrent.Semaphore;
import java.util.logging.Level;
import java.util.logging.Logger;
 
/**
 *
 * @author user
 */
public class Port {
 
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        Semaphore port = new Semaphore(5);
        Ship ship1 = new Ship(port,10);
        Ship ship2 = new Ship(port,10);
        Ship ship3 = new Ship(port,10);
        Ship ship4 = new Ship(port,10);
        Ship ship5 = new Ship(port,10);
        Ship ship6 = new Ship(port,10);
        Ship ship7 = new Ship(port,10);
        Ship ship8 = new Ship(port,10);
        Ship ship9 = new Ship(port,10);
        Ship ship10 = new Ship(port,10);
        
    }
}
 
 
class Ship extends Thread
{
    
    private Semaphore port;
    Ship(Semaphore port,int cargo)
    {
        this.port = port;
        this.start();
       
    }
    @Override 
    public void run()
    {
        getPrint();
        try {
            port.acquire();
            getPrintString();
            port.release();
        } catch (InterruptedException ex) {
            Logger.getLogger(Ship.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
    private void getPrint()
    {
        System.out.println(this.getName() + " waiting for port");
    }
    private void getPrintString()
    {
        System.out.println(this.getName() + " unloading of cargo");
        try {
            
            this.sleep(10000);
        } catch (InterruptedException ex) {
            Logger.getLogger(Ship.class.getName()).log(Level.SEVERE, null, ex);
        }
        System.out.println(this.getName() + " realise cargo");
        
    }
    
}

/**
 * что-то типо блокирующей очереди 
 * текущая загруженность порта может быть не справедлива для всех тредов одновременно,
 *  т.к. этот параметр находится в стеке разных тредов одновременно и может быть ошибочным
 */
 
import net.jcip.annotations.GuardedBy;
import net.jcip.annotations.ThreadSafe;
import java.util.LinkedList;
import java.util.Queue;
@ThreadSafe
public class PortDataBase<E> {
    @GuardedBy("this")
    private Queue<E> data = new LinkedList<E>();
 
    public synchronized void add(E e) {
        while (this.data.size() > 3) {
            System.out.println("Извините порт перегружен, " + Thread.currentThread().getName() + " ожидает очереди когда произведётся отгрузка из порта");
            try {
                wait();
            } catch (InterruptedException e1) {
                System.out.println("итеррапт перехвачен");
            }
        }
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e3) {
            e3.printStackTrace();
        }
        this.data.add(e);
        System.out.println(Thread.currentThread().getName() + " Доставил груз в порт, текущая загруженность порта " + this.data.size() + " из 3");
        notifyAll();
    }
 
    public synchronized E del() {
        while (this.data.size() == 0) {
            System.out.println("Извините, в порту груз отсутствует, " + Thread.currentThread().getName() + " ожидает очереди когда груз поступит в порт");
            try {
                wait();
            } catch (InterruptedException e) {
                System.out.println("итеррапт перехвачен");
            }
        }
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        E rsl = this.data.poll();
        System.out.println(Thread.currentThread().getName() + " Произвёл отгрузку из порта, текущая заполненность порта " + this.data.size() + " из 3");
        notifyAll();
        return rsl;
    }
}

/**
 * Класс корабли
 */
abstract class Ship extends Thread {
 
    public static class ShipDownload extends Ship {
        private final PortDataBase port;
        private int cargo;
 
        public ShipDownload(PortDataBase port, int cargo) {
            this.port = port;
            this.cargo = cargo;
        }
 
        @Override
        public void run() {
            this.port.add(this.cargo);
        }
    }
    public static class ShipUpload extends Ship {
        private final PortDataBase port;
 
        public ShipUpload(PortDataBase port) {
            this.port = port;
        }
 
        @Override
        public void run() {
            this.port.del();
        }
    }
}

import static org.hamcrest.Matchers.is;
import org.junit.Test;
 
import static org.junit.Assert.assertThat;
 
 
public class ShipTest {
    @Test
    public void whentestPortDatabase() throws InterruptedException {
        Thread t = Thread.currentThread();
        t.setName("Корабль expected");
 
        PortDataBase<Integer> port = new PortDataBase<Integer>();
        Thread ship1 = new Thread(new Ship.ShipDownload(port, 10), "Корабль поставщик ship1");
        Thread ship2 = new Thread(new Ship.ShipDownload(port, 10), "Корабль поставщик ship2");
        Thread ship3 = new Thread(new Ship.ShipDownload(port, 10), "Корабль поставщик ship3");
        Thread ship4 = new Thread(new Ship.ShipDownload(port, 10), "Корабль поставщик ship4");
        Thread ship5 = new Thread(new Ship.ShipDownload(port, 10), "Корабль поставщик ship5");
        Thread ship6 = new Thread(new Ship.ShipDownload(port, 10), "Корабль поставщик ship6");
        Thread ship7 = new Thread(new  Ship.ShipUpload(port), "Корабль отгрузчик ship7");
        Thread ship8 = new Thread(new  Ship.ShipUpload(port), "Корабль отгрузчик ship8");
        Thread ship9 = new Thread(new  Ship.ShipUpload(port), "Корабль отгрузчик ship9");
        Thread ship10 = new Thread(new Ship.ShipUpload(port), "Корабль отгрузчик ship10");
        Thread ship11 = new Thread(new Ship.ShipUpload(port), "Корабль отгрузчик ship11");
        
        ship1.start();
        ship2.start();
        ship3.start();
        ship4.start();
        ship5.start();
        ship6.start();
        ship7.start();
        ship8.start();
        ship9.start();
        ship10.start();
        ship11.start();
        
        ship1.join();
        ship2.join();
        ship3.join();
        ship4.join();
        ship5.join();
        ship6.join();
        ship7.join();
        ship8.join();
        ship9.join();
        ship10.join();
        ship11.join();
        
        assertThat(port.del(), is(10));
    }