2

2 つの質問があります...

  1. 特定の時間に 1 つのスレッドのみがアクセスできる関数を含むクラスがあります。これをsynchronized関数またはsynchronizedブロックにしても、異なるスレッドがクラス内でアクセスしているため、複数のスレッドを使用できます。このコードにアクセスするスレッドが 1 つだけであることを確認するにはどうすればよいですか? (以下のコード例を参照)

  2. 同期関数を使用すると、関数の呼び出しがキューに入れられます。関数への最後の呼び出しのみがコードにアクセスできるようにする方法はありますか? そのため、Thread1 が現在関数にアクセスしている場合、Thread2 と Thread3 が (この順序で) アクセスしようとすると、Thread1 が完了すると Thread3 のみがアクセスを許可されます。

    public void doATask() {
    // I create a new thread so the interface is not blocked
    new Thread(new Runnable() {

        @Override
        public void run() {
            doBackgroundTask();
        }
    }).start();
}

private void doBackgroundTask(MyObject obj) {
    // perform long task here that is only being run by one thread
    // and also only accepts the last queued thread
}

助けてくれてありがとう！

4

2 に答える 2

2

例の 2 番目のスレッドがreturn. 次のようになります。

private volatile Thread lastThread;
private final ReentrantLock lock = new ReentrantLock();

private void doBackgroundTask(Object obj) throws InterruptedException {
    Thread currentThread = Thread.currentThread();
    lastThread = currentThread;
    try {
        // wait until lock available
        lock.lockInterruptibly();
        // if a thread has arrived in the meantime, exit and release the lock
        if (lastThread != currentThread) return; 
        // otherwise
        // perform long task here that is only being run by one thread
        // and also only accepts the last queued thread
    } finally {
        lock.unlock();
    }
}

スレッドのインターリーブと T2 が何もせずに終了することを示す追加のログを使用した完全な動作テスト:

class Test {

    private volatile Thread lastThread;
    private final ReentrantLock lock = new ReentrantLock();

    public static void main(String[] args) throws Exception {
        final Test instance  = new Test();
        Runnable r = new Runnable() {

            @Override
            public void run() {
                try {
                    instance.doBackgroundTask(null);
                } catch (InterruptedException ignore) {}
            }
        };
        Thread t1 = new Thread(r, "T1");
        Thread t2 = new Thread(r, "T2");
        Thread t3 = new Thread(r, "T3");
        t1.start();
        Thread.sleep(100);
        t2.start();
        Thread.sleep(100);
        t3.start();
    }

    private void doBackgroundTask(Object obj) throws InterruptedException {
        Thread currentThread = Thread.currentThread();
        System.out.println("[" + currentThread.getName() + "] entering");
        lastThread = currentThread;
        try {
            // wait until lock available
            lock.lockInterruptibly();
            // if a thread has arrived in the meantime, exit and release the lock
            if (lastThread != currentThread) return;
            // otherwise
            // perform long task here that is only being run by one thread
            // and also only accepts the last queued thread
            System.out.println("[" + currentThread.getName() + "] Thinking deeply");
            Thread.sleep(1000);
            System.out.println("[" + currentThread.getName() + "] I'm done");
        } finally {
            lock.unlock();
            System.out.println("[" + currentThread.getName() + "] exiting");
        }
    }
}

出力：

[T1] entering
[T1] Thinking deeply
[T2] entering
[T3] entering
[T1] I'm done
[T1] exiting
[T2] exiting
[T3] Thinking deeply
[T3] I'm done
[T3] exiting
于 2013-03-28T02:49:21.020 に答える
2

あなたが望むのは、おそらく何らかの作業を行うためのシグナルを待機するワーカー スレッドです。doATask()信号を送信して作業をトリガーするだけです。累積信号は 1 つの信号に相当します。

final Object lock = new Object();
MyObject param = null;

public void doATask(arg) 
    synchronized(lock)
        param=arg;
        lock.notify();

MyObject awaitTask()
    synchronized(lock)
        while(param==null)
            lock.wait();
        tmp=param;
        param=null;
        return tmp;

// worker thread

public void run()
    while(true)
        arg = awaitTask();
        doBackgroundTask(arg);
于 2013-03-28T03:05:10.187 に答える