1

我想在我的多线程下载程序中计算当前百分比。但是有一个奇怪的问题。第二次下载时的lastDownloadSize必须是lastDown的write和lastDownloadSize之和。 例子

有我的代码

private long getDownloadSize() {
    synchronized (this) {
        final AtomicLong totalWriteCount = new AtomicLong(0);
        final AtomicLong lastDownloadSize = new AtomicLong(0);
        for (DownloadTask task : downloadTasks) {
            final long writeCount = task.getWriteCount();
            totalWriteCount.addAndGet(writeCount);
            final long downloadSize = task.getPosition().getDownloadSize();
            lastDownloadSize.addAndGet(downloadSize);
        }
        System.out.println("=====  writeCount : " + totalWriteCount + "lastDownloadSize : " + lastDownloadSize);
        return totalWriteCount.addAndGet(lastDownloadSize.get());
    }
}
4

2 回答 2

1

你的totalWriteCount和lastDownloadSize变量是getDownloadSize()方法的局部变量。在这种情况下，使用 没有意义AtomicLong，因为只有单个线程可以访问它们。

您可能的意思是让您totalWriteCount的lastDownloadSize班级成员：

class SomeClass {
    // ...
    final AtomicLong totalWriteCount = new AtomicLong(0);
    final AtomicLong lastDownloadSize = new AtomicLong(0);
    // ...

    private long getDownloadSize() {
        synchronized (this) {
            for (DownloadTask task : downloadTasks) {
                final long writeCount = task.getWriteCount();
                totalWriteCount.addAndGet(writeCount);
                final long downloadSize = task.getPosition().getDownloadSize();
                lastDownloadSize.addAndGet(downloadSize);
            }
            System.out.println("=====  writeCount : " + totalWriteCount + "lastDownloadSize : " + lastDownloadSize);
            return totalWriteCount.addAndGet(lastDownloadSize.get());
        }
    }
}

但是，同样在这种情况下，如果它们仅在synchronized(this)块内访问，则不需要使用AtomicLongs，因为同步块已经确保它们只能由单个线程同时访问。

于 2018-06-01T06:45:19.470 回答
1

您当前的设置不起作用，因为您使用AtomicLong了错误的方式。在单个线程中定义任何Atomic-class 只是对该 API 的误用。

现在为什么我说单线程，当有人进入你的方法时你正在同步，这只是说一次只有一个线程可以使用所述方法。这导致了我们的问题：

  • 是AtomicLong一个局部变量

您可能想将您的downloadSizeand定义totalWriteCount为您的. 例如：class

public class YourClass {
    private final AtomicLong totalWriteCount = new AtomicLong(0);        
    private final AtomicLong downloadSize = new AtomicLong(0);

    /* constructors and other methods */

    private synchronized long getDownloadSize() {
        for (DownloadTask task : downloadTasks) {
            final long writeCount = task.getWriteCount();
            totalWriteCount.addAndGet(writeCount);
            final long downloadSize = task.getPosition().getDownloadSize();
            lastDownloadSize.addAndGet(downloadSize);
        }
        System.out.println("=====  writeCount : " + totalWriteCount + "lastDownloadSize : " + lastDownloadSize);
        return totalWriteCount.addAndGet(lastDownloadSize.get());
    }
}
于 2018-06-01T06:46:41.083 回答