})
        }
        executorService.awaitTermination(5, TimeUnit.SECONDS)
        then:
        (1..1000).each { num ->
            def updatedLocation = dir.file(num).file("in-dir.txt")
            assertIsFileSnapshot(read(updatedLocation), updatedLocation)
        }

        cleanup:
        executorService.shutdown()
    }

            }
        }

        void allowStat(boolean allowed) {
            this.statAllowed = allowed
        }
    }

    void assertIsFileSnapshot(FileSystemLocationSnapshot snapshot, File file) {
        assert snapshot.absolutePath == file.absolutePath
        assert snapshot.name == file.name
        assert snapshot.type == FileType.RegularFile