Клиент-серверное приложение

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class Schedikov extends javax.swing.JFrame {
 
    public BlockingQueue<Message> queue;
    Producer  producer1 = new Producer(getQueue());
    Consumer1 consumer1 = new Consumer1(getQueue());
    Consumer2 consumer2 = new Consumer2(getQueue());
    Consumer3 consumer3 = new Consumer3(getQueue());
    Consumer4 consumer4 = new Consumer4(getQueue());
    Consumer5 consumer5 = new Consumer5(getQueue());
    private int w;
    private int la, fa;
 
    private Schedikov() {
        this.queue = new ArrayBlockingQueue<>(10000);
        initComponents();
    } private void jButton2ActionPerformed(java.awt.event.ActionEvent evt) {                                         
        System.exit(0);
    }                                        
 
    private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {                                         
     
 
                         
           String t = jTextField1.getText();
        w = (int) (Double.parseDouble(t) * 1000);
 
        String r = jTextField2.getText();
        la = (int) (Double.parseDouble(r));
        
        
        
        new Thread(consumer1).start();
                            new Thread(consumer2).start();
                            new Thread(consumer3).start();
                            new Thread(consumer4).start();
                            new Thread(consumer5).start();
       
 
     
    }                                        
 
    private void jButton3ActionPerformed(java.awt.event.ActionEvent evt) {                                         
        jTextArea1.setText("");
        jTextArea2.setText("");
    }                                        
 
    /**
     * @param args the command line arguments
     */
    public static void main(String args[]) { java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new Schedikov().setVisible(true);
            }
        });
    }
    // Variables declaration - do not modify                     
    private javax.swing.JButton jButton1;
    private javax.swing.JButton jButton2;
    private javax.swing.JButton jButton3;
    private javax.swing.JLabel jLabel1;
    private javax.swing.JLabel jLabel10;
    private javax.swing.JLabel jLabel11;
    private javax.swing.JLabel jLabel12;
    private javax.swing.JLabel jLabel13;
    private javax.swing.JLabel jLabel2;
    private javax.swing.JLabel jLabel3;
    private javax.swing.JLabel jLabel4;
    private javax.swing.JLabel jLabel5;
    private javax.swing.JLabel jLabel6;
    private javax.swing.JLabel jLabel8;
    private javax.swing.JLabel jLabel9;
    private javax.swing.JProgressBar jProgressBar1;
    private javax.swing.JProgressBar jProgressBar2;
    private javax.swing.JProgressBar jProgressBar3;
    private javax.swing.JProgressBar jProgressBar4;
    private javax.swing.JProgressBar jProgressBar5;
    private javax.swing.JProgressBar jProgressBar6;
    private javax.swing.JScrollPane jScrollPane1;
    private javax.swing.JScrollPane jScrollPane2;
    private javax.swing.JTextArea jTextArea1;
    private javax.swing.JTextArea jTextArea2;
    private javax.swing.JTextField jTextField1;
    private javax.swing.JTextField jTextField2;
    // End of variables declaration                   
 
    /**
     * @return the queue
     */
    public BlockingQueue<Message> getQueue() {
        return queue;
    }
 
    /**
     * @param queue the queue to set
     */
    public void setQueue(BlockingQueue<Message> queue) {
        this.queue = queue;
    }
 
    public class Consumer1 implements Runnable {
 
        private final BlockingQueue<Message> queue;
 
        private Consumer1(BlockingQueue<Message> q) {
            this.queue = q;
        }
 
        @Override
        public void run() {
 
            try {
 
                Message msg;
 
                while (!"выход".equals((msg = queue.take()).getMsg())) {
                    fa--;
                    //ru = fa - fi - fy;
                    jLabel10.setText("" + fa);
                    String rez = "Заявка № " + msg.getMsg() + " обработана 1 каналом";
 
                    for (int i = 0; i < w; i++) {
 
                        jProgressBar2.setMaximum(w);
                        jProgressBar2.setMinimum(0);
                        jProgressBar2.setValue(i);
 
                        Thread.sleep(1);
                    }
 
                    jTextArea2.setText(rez + "\r\n" + jTextArea2.getText());
 
 
                }
 
            } catch (InterruptedException e) {
                e.printStackTrace();
 
            }
        }
    }
 
    public class Consumer2 implements Runnable {
 
        private final BlockingQueue<Message> queue;
 
        private Consumer2(BlockingQueue<Message> q) {
            this.queue = q;
        }
 
        @Override
        public void run() {
 
            try {
 
                Message msg;
 
                while (!"выход".equals((msg = queue.take()).getMsg())) {
                    fa--;
                    //ru = fa - fi - fy;
                    jLabel10.setText("" + fa);
                    String rez = "Заявка № " + msg.getMsg() + " обработана 2 каналом";
 
                    for (int i = 0; i < w; i++) {
                        jProgressBar3.setMaximum(w);
                        jProgressBar3.setMinimum(0);
                        jProgressBar3.setValue(i);
                        Thread.sleep(1);
                    }
 
                    jTextArea2.setText(rez + "\r\n" + jTextArea2.getText());
 
 
 
                }
 
            } catch (InterruptedException e) {
                e.printStackTrace();
 
            }
 
        }
    }
 
    public class Consumer3 implements Runnable {
 
        private final BlockingQueue<Message> queue;
 
        private Consumer3(BlockingQueue<Message> q) {
            this.queue = q;
        }
 
        @Override
        public void run() {
 
            try {
 
                Message msg;
 
                while (!"выход".equals((msg = queue.take()).getMsg())) {
                    fa--;
                    //ru = fa - fi - fy;
                    jLabel10.setText("" + fa);
                    String rez = "Заявка № " + msg.getMsg() + " обработана 3 каналом";
 
                    for (int i = 0; i < w; i++) {
                        jProgressBar4.setMaximum(w);
                        jProgressBar4.setMinimum(0);
                        jProgressBar4.setValue(i);
                        Thread.sleep(1);
                    }
 
                    jTextArea2.setText(rez + "\r\n" + jTextArea2.getText());
 
 
 
                }
 
            } catch (InterruptedException e) {
                e.printStackTrace();
 
            }
 
        }
    }
 
    public class Consumer4 implements Runnable {
 
        private final BlockingQueue<Message> queue;
 
        private Consumer4(BlockingQueue<Message> q) {
            this.queue = q;
        }
 
        @Override
        public void run() {
 
            try {
 
                Message msg;
 
                while (!"выход".equals((msg = queue.take()).getMsg())) {
                    fa--;
                    //ru = fa - fi - fy;
                    jLabel10.setText("" + fa);
                    String rez = "Заявка № " + msg.getMsg() + " обработана 4 каналом";
 
                    for (int i = 0; i < w; i++) {
                        jProgressBar5.setMaximum(w);
                        jProgressBar5.setMinimum(0);
                        jProgressBar5.setValue(i);
                        Thread.sleep(1);
                    }
 
                    jTextArea2.setText(rez + "\r\n" + jTextArea2.getText());
 
 
 
                }
 
            } catch (InterruptedException e) {
                e.printStackTrace();
 
            }
 
        }
    }
 
    public class Consumer5 implements Runnable {
 
        private final BlockingQueue<Message> queue;
 
        private Consumer5(BlockingQueue<Message> q) {
            this.queue = q;
        }
 
        @Override
        public void run() {
 
            try {
 
                Message msg;
 
                while (!"выход".equals((msg = queue.take()).getMsg())) {
                    fa--;
                    //ru = fa - fi - fy;
                    jLabel10.setText("" + fa);
                    String rez = "Заявка № " + msg.getMsg() + " обработана 5 каналом";
 
                    for (int i = 0; i < w; i++) {
                        jProgressBar6.setMaximum(w);
                        jProgressBar6.setMinimum(0);
                        jProgressBar6.setValue(i);
                        Thread.sleep(1);
                    }
 
                    jTextArea2.setText(rez + "\r\n" + jTextArea2.getText());
 
 
 
                }
 
            } catch (InterruptedException e) {
                e.printStackTrace();
 
            }
 
        }
    }
 
    class Producer implements Runnable {
 
        private final BlockingQueue<Message> queue;
 
        public Producer(BlockingQueue<Message> q) {
            this.queue = q;
        }
 
        @Override
        public void run() {
 
            Random r = new Random();
            for (int i = 1; i < 100000; i++) {
 
 
 
                Message msg = new Message("" + i);
                try {
                    double c = Math.abs(Math.log(r.nextDouble()) * la);
                    long wer = (long) (c * 1000);
                    int w = (int) wer;
                    for (int index = 0; index < w; index++) {
                        jProgressBar1.setMaximum(w);
                        jProgressBar1.setMinimum(0);
                        jProgressBar1.setValue(index);
                        Thread.sleep(1);
 
                    }
 
                    queue.put(msg);
                    String p = "Заявка №" + msg.getMsg() + " поступила";
                    jTextArea1.setText(p + "\r\n" + jTextArea1.getText());
 
 
                } catch (InterruptedException e) {
                    e.printStackTrace();
 
 
 
                }
 
                fa++;
                //ru = fa - fi - fy;
                jLabel10.setText("" + fa);
            }
 
        }
    }
}