ExecutorService, ArrayList<Future<>>

@RequiemMass · Регистрация: 06.01.2012

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

Такой вот код, получаю nullPointException на строчке

Java
1
     FutureCount.add(pool.submit(new Counter(startValue,TH1)));

, когда пытаюсь добавить в ArrayList

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
  private ArrayList<Future> FutureCount;
//.....тут много кода
private class StartListener implements ActionListener
    {
        public void actionPerformed(ActionEvent event)
        {  
           try
           {
               long startValue = Long.valueOf(value.getText());
               ExecutorService pool = Executors.newCachedThreadPool();            
               FutureCount.add(pool.submit(new Counter(startValue,TH1)));
               FutureCount.add(pool.submit(new Counter(startValue,TH2)));
               FutureCount.add(pool.submit(new Counter(startValue,TH3)));       
           }
           catch(NumberFormatException e){ e.printStackTrace(); }   
        }     
    }
    private class Counter implements Runnable
        {
            private long valueStart=0;
            private JTextField nowCounting;
            
            public Counter(long valueStart,JTextField TF)
            {        
                this.valueStart=valueStart;
                nowCounting=TF;
            }
 
            public void run()
            {
                long count;
                while(valueStart > 0)
                {
                    valueStart--;
                    nowCounting.setText(Long.toString(valueStart));
                }
            }
        }

Метод sumbit если передаешь туда Runnable должен вернуть объект по которому можно остановить поток, выполнить isCanceled(), isDone(). Идея состоит в том, чтобы кнопочкой запускать потоки и останавливать. Почему он возвращает null, и не добавляется в ArrayList не понимаю.
Exception in thread "AWT-EventQueue-0" java.lang.NullPointerException.

@exiqa · 10.03.2012, 23:13

из Вашего кода не видно, чтобы эрейлист был инстанцирован

@mutagen · 10.03.2012, 23:19

И ещё одно, чтобы заюзать Future его должен возвращать Callable, а не Runnable, поэтому имплементить в Counter надо его.

@RequiemMass · 10.03.2012, 23:29 **[ТС]**

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

И ещё одно, чтобы заюзать Future его должен возвращать Callable, а не Runnable, поэтому имплементить в Counter надо его.

Можно и так как я написал в Runnable пихать.

Добавлено через 38 секунд

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

из Вашего кода не видно, чтобы эрейлист был инстанцирован

Спасибо, до сих пор забываю инициализировать переменные. Всё работает так как я хочу и останавливается по нажатии кнопки стоп ^^.

@mutagen · 10.03.2012, 23:35

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

Можно и так как я написал в Runnable пихать.

Future содержит в себе результат который будет доступен по завершению работы потока с Callable, а что у вас будет в результате выполнения Runnable - будет null.
Можно пихать это в эксекьютор - ему пофигу что запускать, а футурка требует возврата значения.

@RequiemMass · 10.03.2012, 23:43 **[ТС]**

Я тоже сначала думал, что не будет работать. Метод sumbit вернёт Future я добавляю их в ArrayList и потом кнопкой stop пробегаюсь по нему и выполняю инструкцию

Java
1
(FutureCount.get(i)).cancel(true);

и всё останавливается. Я уже не знаю как вас убедить, что это работает.

@mutagen · 10.03.2012, 23:57

это не работает, это непонимание зачем что нужно, вот вам доказательство:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
 
public class FutureCalRun {
 
    static class A implements Runnable {
 
        @Override
        public void run() {
            try {
                Thread.sleep((long)(Math.random()*1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
 
    }
 
    static class B implements Callable<Integer> {
 
        @Override
        public Integer call() throws Exception {
            Thread.sleep((long)(Math.random()*1000));
            return 1;
        }
 
    }
 
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        A[] a = new A[10];
        B[] b = new B[10];
        Arrays.fill(a, new A());
        Arrays.fill(b, new B());
        ExecutorService ex = Executors.newFixedThreadPool(2);
        List<Future> la = new ArrayList<Future>();
        List<Future> lb = new ArrayList<Future>();
        for (A a2 : a) {
            la.add(ex.submit(a2));
        }
        for (B b2 : b) {
            lb.add(ex.submit(b2));
        }
        
        for (Future future : la) {
            System.out.println(future.get());
        }
        for (Future future : lb) {
            System.out.println(future.get());
        }
                ex.shutdown();
    }
 
}

@RequiemMass · 10.03.2012, 23:59 **[ТС]**

Такой вот тестик у меня вышел

Много кода

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
package svtest;
import java.util.concurrent.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;
import java.util.*;
/**
 *
 * @author Евгений
 */
public class SVtest {
 
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
       //ExecutorService pool = Executors.newCachedThreadPool();  
       JFrame main = new MainFrame();
       main.show();
    }   
}
class MainFrame extends JFrame
{
    private static final int DEFAULT_WIDTH=300;
    private static final int DEFAULT_HEIGHT=100;
    
    private JTextField TH1=new JTextField(12);
    private JTextField TH2=new JTextField(12);
    private JTextField TH3=new JTextField(12);
    
    private JTextField value=new JTextField(12);
    private JButton startButton = new JButton("Start");
    private JButton stopButton = new JButton("Stop");
    
    private ArrayList<Future> FutureCount= new ArrayList<Future>();
    
    private JPanel mainPanel=new JPanel(new GridLayout(2,3));
    
    public MainFrame()
    {
        setLocationRelativeTo(null);
        setResizable(false);
        setTitle("SVTest");
        setSize(DEFAULT_WIDTH,DEFAULT_HEIGHT);   
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        
        addMonitorGui();
        addTaskGui();
        add(mainPanel);
    }
    
    private void addMonitorGui()
    {
        JPanel monitorPanel = new JPanel(new GridLayout(0,3));
        monitorPanel.add(TH1);
        monitorPanel.add(TH2);
        monitorPanel.add(TH3);
        mainPanel.add(monitorPanel,BorderLayout.CENTER);
    }
    private void addTaskGui()
    {
        JPanel taskPanel = new JPanel(new GridLayout(0,3));
        taskPanel.add(value);
        stopButton.addActionListener(new  CancelListener() );
        taskPanel.add(stopButton);
        startButton.addActionListener(new StartListener());
        taskPanel.add(startButton);    
        mainPanel.add(taskPanel,BorderLayout.SOUTH);
    }
    
    private class StartListener implements ActionListener
    {
        public void actionPerformed(ActionEvent event)
        {  
           try
           {
               long startValue = Long.valueOf(value.getText());
               ExecutorService pool = Executors.newCachedThreadPool();            
               FutureCount.add(pool.submit(new Counter(startValue,TH1)));
               FutureCount.add(pool.submit(new Counter(startValue,TH2)));
               FutureCount.add(pool.submit(new Counter(startValue,TH3)));
               
               
           }
           catch(NumberFormatException e){ e.printStackTrace(); }   
        }     
    }
    private class CancelListener implements ActionListener
    {
        public void actionPerformed(ActionEvent event)
        {
            for (int i=0;i<FutureCount.size();i++)
                (FutureCount.get(i)).cancel(true);
        }
    }
    
    private class Counter implements Runnable
        {
            private long valueStart=0;
            private JTextField nowCounting;
            
            public Counter(long valueStart,JTextField TF)
            {        
                this.valueStart=valueStart;
                nowCounting=TF;
            }
 
            public void run()
            {
                long count;
                while(valueStart > 0)
                {
                    valueStart--;
                    nowCounting.setText(Long.toString(valueStart));
                }
            }
        } 
}

Метод get() вернёт null, но будут работать isDone(),cancel(),isCancelled() для Runnable. Я просто изначально думал, что спор как раз в том можно ли для Runnable получить Future.

@mutagen · 11.03.2012, 00:17

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

Метод get() вернёт null, но будут работать isDone(),cancel(),isCancelled() для Runnable

Для отлова этих методов вам нужно было просто создавать триды самому из рунаблов и класть эти ссылки в массив,а уж потом в фориче передавать их на запуск эксекьютору.
Тогда прямо по ссылкам на триды все методы доступны.
А футурка создавалась какраз чтобы забрать результаты работы потока по окончанию его работы.
А вы из пушки по воробьям
нет всётаки isCancelled() isDone() ... возможны только из Future, всё ок, я наконец сообразил что задумка была в управлении потоками

@RequiemMass · 11.03.2012, 00:26 **[ТС]**

Спасибо за консультацию, а могли бы вы набросать примерчик того механизма, который вы описали а то я как то на словах не совсем понял. Понял только, что можно было сделать проще.

Новые блоги и статьи Все статьи Все блоги /
Подключение Box2D v3 к SDL3 для Android: физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .	Загрузка PNG с альфа-каналом на SDL3 для Android: с помощью SDL3_image 8Observer8 27.01.2026 Содержание блога SDL3_image - это библиотека для загрузки и работы с изображениями. Эта пошаговая инструкция покажет, как загрузить и вывести на экран смартфона картинку с альфа-каналом, то есть с. . .
Влияние грибов на сукцессию anaschu 26.01.2026 Бифуркационные изменения массы гриба происходят тогда, когда мы уменьшаем массу компоста в 10 раз, а скорость прироста биомассы уменьшаем в три раза. Скорость прироста биомассы может уменьшаться за. . .	Воспроизведение звукового файла с помощью SDL3_mixer при касании экрана Android 8Observer8 26.01.2026 Содержание блога SDL3_mixer - это библиотека я для воспроизведения аудио. В отличие от инструкции по добавлению текста код по проигрыванию звука уже содержится в шаблоне примера. Нужно только. . .	Установка Android SDK, NDK, JDK, CMake и т.д. 8Observer8 25.01.2026 Содержание блога Перейдите по ссылке: https:/ / developer. android. com/ studio и в самом низу страницы кликните по архиву "commandlinetools-win-xxxxxx_latest. zip" Извлеките архив и вы увидите. . .	Вывод текста со шрифтом TTF на Android с помощью библиотеки SDL3_ttf 8Observer8 25.01.2026 Содержание блога Если у вас не установлены Android SDK, NDK, JDK, и т. д. то сделайте это по следующей инструкции: Установка Android SDK, NDK, JDK, CMake и т. д. Сборка примера Скачайте. . .

@exiqa 487 / 333 / 71 Регистрация: 24.12.2011 Сообщений: 591
	10.03.2012, 23:13
	из Вашего кода не видно, чтобы эрейлист был инстанцирован 1

@mutagen 2587 / 2260 / 257 Регистрация: 14.09.2011 Сообщений: 5,185 Записей в блоге: 18
	10.03.2012, 23:19
	И ещё одно, чтобы заюзать Future его должен возвращать Callable, а не Runnable, поэтому имплементить в Counter надо его. 0

@RequiemMass 92 / 92 / 18 Регистрация: 06.01.2012 Сообщений: 394
	11.03.2012, 00:26 [ТС]
	Спасибо за консультацию, а могли бы вы набросать примерчик того механизма, который вы описали а то я как то на словах не совсем понял. Понял только, что можно было сделать проще. 0