if ( this.future != null ) {
            this.future.cancel(true);
        }
        this.future = this.executor.submit(w);
        Thread.sleep(1000);
    }


    @Test
    public void testWatchCreate () throws CIFSException, MalformedURLException, UnknownHostException, InterruptedException, ExecutionException {

            try ( SmbTreeHandle th = f.getTreeHandle() ) {
                Assume.assumeTrue("Not SMB2", th.isSMB2());
            }

            f.exists();
            Thread.sleep(wait);

            try ( SmbResource r = f.resolve("test") ) {
                r.exists();
            }
        }
        catch ( SmbUnsupportedOperationException e ) {

        try ( SmbFile f = getDefaultShareRoot() ) {
            checkConnection(f);
            while ( true ) {
                f.list();
                Thread.sleep(5000);
            }

        }
    }

            public void run () {

                try {
                    synchronized ( lock ) {
                        lock.wait(1000);
                    }

                    Thread.sleep(100);
                    t.interrupt();
                }
                catch ( InterruptedException e ) {
                    e.printStackTrace();
                }
            }
        });

                }

                try ( InputStream is = f.getInputStream() ) {
                    for ( int i = 0; i < 8; i++ ) {
                        is.read();
                        Thread.sleep(soTimeout);
                    }
                }
            }
            finally {
                f.delete();
            }
        }
    }


    @SuppressWarnings ( "resource" )

                    if (expire > ctime)
                        delay = expire - ctime;
                }

if (delay > 2)
System.out.println("delay=" + delay);
                Thread.sleep(delay);
            } while (delay > 2);

            synchronized (t) {
                t.notifyAll();
            }
//System.out.println("numComplete=" + t.numComplete + ",numThreads=" + t.numThreads);

                    // immediately
                    Thread.sleep(500 + RAND.nextInt(1000));
                }
            }
            catch ( InterruptedException e ) {
                log.debug("interrupted sleep in send", e);
            }

            if ( request != null ) {
                log.debug("Restting request");