MyThreads.java

package com.company;

import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;

/**
 * Created by senior on 18.06.15.
 */
public class MyThreads implements Runnable {

    private String path;
    private FileVisitCounter fileVisitor;
    private String fileForWrite;
    private long count;

    public String getPath() {
        return path;
    }

    public long getCount() {
        return count;
    }

    public MyThreads(String path, FileVisitCounter fileVisitor, String fileForWrite) {
        this.path = path;
        this.fileVisitor = fileVisitor;
        this.fileForWrite = fileForWrite;

    }


    @Override
    public void run() {
        Path p = new File(path).toPath();
        try {
            Files.walkFileTree(p, fileVisitor);
            count = fileVisitor.getCount();
            System.out.println(Thread.currentThread().getName() + "\t" + this.getCount() + "\t" + this.getPath());
            new  MyCSVWriter(fileForWrite).putResults(path,count);

        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}