Кривые руки и Reentrant Lock

@Izul · Регистрация: 19.10.2016

Author24 — интернет-сервис помощи студентам

Добрый день, суть вопроса такова, как изменить данный код, чтобы происходил лок на цикле и последовательность выдавала в нужном порядке от 0 до N :

Java

 
public class Main {
 
    public static void main(String[] args)
    {
        Lock lock=new ReentrantLock();
        ExecutorService service= Executors.newFixedThreadPool(2);
        for (int i=0;i<10;i++)
        {
            lock.lock();
            service.submit(new SomeClass(i));
            lock.unlock();
        }
        service.submit(new OtherClass());
    }
}
public class SomeClass implements Callable {
 
    SomeClass(int i){
        this.i=i;
    }
    private int i;
    @Override
    public Object call() throws Exception {
        System.out.println("Метод call из SomeClass была вызвана "+i+" раз");
        Thread.sleep(1000);
        return "Строка отработала и выдедена из return";
    }
}
 
public class OtherClass implements Runnable{
 
    @Override
    public void run() {
    System.out.println("Отработал run");
    }
}

@korvin_ · 22.11.2017, 00:27

Сообщение от Izul

чтобы происходил лок на цикле и последовательность выдавала в нужном порядке от 0 до N

Какая последовательность?

@Izul · 22.11.2017, 10:14 **[ТС]**

Последовательность вызовов submit'ов в цикле

Java

for (int i=0;i<10;i++)
        {
            lock.lock();
            service.submit(new SomeClass(i));
            lock.unlock();
        }

@LeX · 22.11.2017, 12:00

lock и unlock надо вызывать внутри метода call()

@korvin_ · 22.11.2017, 22:52

Сообщение от LeX

lock и unlock надо вызывать внутри метода call()

Как это гарантирует, что поток с инстансом SomeClass(1) вызовет SomeClass::call(), чем поток с инстансом SomeClass(2)?

Izul, я так и не понял, что ты в результате получить-то хочешь?

@Izul · 22.11.2017, 23:23 **[ТС]**

Что-то около :
Метод call из SomeClass была вызвана "+1+" раз"
Метод call из SomeClass была вызвана "+2+" раз"
и т.д до 10 с неизменным порядком от 0 до 9 и уже после :"Отработан метод run".
Но пока происходит так, как на пикче. + проверил постановку локов в call, как отписывал Lex

Java

@Override
    public Object call() throws Exception {
        lock.lock();
        System.out.println("Метод call из SomeClass была вызвана "+i+" раз");
        Thread.sleep(1000);
        lock.unlock();
        return "Строка отработала и выведена из return";
    }

, но это работает примерно никак

@korvin_ · 23.11.2017, 01:52

Сообщение от Izul

Что-то около

Java

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
import java.util.concurrent.locks.ReentrantLock;
 
public final class SomeShit {
 
    public static void main(String[] args) throws Exception {
        final int n = 10;
        final ExecutorService service = Executors.newFixedThreadPool(2);
        final CompletionService<String> completionService = new ExecutorCompletionService<>(service);
        for (int i = 0; i < n; i++) {
            completionService.submit(new SomeClass());
        }
        final List<String> results = new ArrayList<>(n);
        for (int i = 0; i < n; i++) {
            final Future<String> completedFuture = completionService.take();
            results.add(completedFuture.get());
        }
        results.forEach(System.out::println);
        service.submit(() -> System.out.println("Done"));
        service.shutdown();
    }
}
 
final class SomeClass implements Callable<String> {
 
    private static final ReentrantLock LOCK = new ReentrantLock();
    private static int ID = 0;
 
    @Override
    public String call() throws Exception {
        LOCK.lock();
        ID++;
        final int i = ID;
        System.out.println("Method call() was called " + i + " time(s)");
        LOCK.unlock();
        Thread.sleep(ThreadLocalRandom.current().nextInt(100, 5000));
        return "Method call() #" + i + " completed";
    }
}

@LeX · 24.11.2017, 04:59

korvin_, как этот код поможет тс? Да, вывод будет в нужном порядке, но суть то другая, вывод должен быть в потоках.

Izul, делай lock в main, а unlock внутри потока

@korvin_ · 24.11.2017, 09:01

Сообщение от LeX

Да, вывод будет в нужном порядке, но суть то другая, вывод должен быть в потоках.

А у меня он где? Мой метод call в точности повторяет метод ТС, за исключением внесения счётчика внутрь него, чтобы индексация вызовов call соответствовала порядку, который он хочет.

Добавлено через 20 минут
Если ты про ожидание завершения выполнения всех тасок перед тем как вывести их результаты, то это можно и убрать, сделал просто, чтобы не смешивался вывод сообщений о вызове call и результатов.

Java

import java.util.concurrent.*;
import java.util.concurrent.locks.ReentrantLock;
import java.util.function.IntConsumer;
 
public final class SomeShit {
 
    public static void main(String[] args) throws Exception {
        final int n = 10;
        final ExecutorService service = Executors.newFixedThreadPool(2);
        final CompletionService<String> completionService = new ExecutorCompletionService<>(service);
        final Id id = new Id();
        for (int i = 0; i < n; i++) {
            completionService.submit(new SomeClass(id));
        }
        for (int i = 0; i < n; i++) {
            final Future<String> completedFuture = completionService.take();
            System.out.println("\t" + completedFuture.get());
        }
        service.submit(() -> System.out.println("Done"));
        service.shutdown();
    }
}
 
final class SomeClass implements Callable<String> {
 
    private final Id id;
 
    SomeClass(Id id) {
        this.id = id;
    }
 
    @Override
    public String call() throws Exception {
        final int i = id.newId(newId -> System.out.println("Method call() was called " + newId + " time(s)"));
        Thread.sleep(ThreadLocalRandom.current().nextInt(100, 5000));
        return "Method call() #" + i + " completed";
    }
}
 
final class Id {
 
    private final ReentrantLock lock = new ReentrantLock();
    private int currentId = 0;
 
    int newId() {
        lock.lock();
        final int newId = ++currentId;
        lock.unlock();
        return newId;
    }
 
    int newId(IntConsumer newIdConsumer) {
        lock.lock();
        final int newId = ++currentId;
        try {
            newIdConsumer.accept(newId);
        } finally {
            lock.unlock();
        }
        return newId;
    }
}

@korvin_ 4486 / 2721 / 485 Регистрация: 28.04.2012 Сообщений: 8,590
	22.11.2017, 00:27	2
	Сообщение от Izul чтобы происходил лок на цикле и последовательность выдавала в нужном порядке от 0 до N Какая последовательность? 0

@LeX 378 / 370 / 114 Регистрация: 30.06.2010 Сообщений: 1,445
	22.11.2017, 12:00	4
	lock и unlock надо вызывать внутри метода call() 0

@korvin_ 4486 / 2721 / 485 Регистрация: 28.04.2012 Сообщений: 8,590
	22.11.2017, 22:52	5
	Сообщение от LeX lock и unlock надо вызывать внутри метода call() Как это гарантирует, что поток с инстансом SomeClass(1) вызовет SomeClass::call(), чем поток с инстансом SomeClass(2)? Izul, я так и не понял, что ты в результате получить-то хочешь? 0

@LeX 378 / 370 / 114 Регистрация: 30.06.2010 Сообщений: 1,445
	24.11.2017, 04:59	8
	korvin_, как этот код поможет тс? Да, вывод будет в нужном порядке, но суть то другая, вывод должен быть в потоках. Izul, делай lock в main, а unlock внутри потока 0

	24.11.2017, 09:01