Java - Synchronizacja i Koordynacja wątków - drugi wątek nie wstaje

 public class Main {

  public static void main(String[] args)throws InterruptedException  {
  
	  (new Thread(new Wczytywanie())).start();
	 (new Thread(new Weight())). start();
		}
}
 

import java.util.ArrayList;
public class Towary {
int id_towaru;
double waga;
int idtest =1111;
double wagatest = 23131;
static int countobj = 0;
static int notifnewobj = 200;
public static ArrayList<Towary> listatowarow = new ArrayList<Towary>();

public Towary(int id_towaru, double waga){
	this.id_towaru = id_towaru;
	this.waga=waga;
	countobj ++ ;
}
void add(int a, double b){
	listatowarow.add(new Towary(a, b));
}
public static int countob(){
	return countobj;
}

double returnweight(){
	return waga;
}

}

import java.io.File;
import java.util.Scanner;
import java.io.FileNotFoundException;
public class Wczytywanie implements Runnable {
	public static boolean state = false;
static int count = 0;
	
	public void run() {

	

		  Scanner s;
		try {

			s = new Scanner(new File("C:/Users/Janusz/Desktop/Towary.txt"));
			synchronized (this){
				
			while (s.hasNext()){
				if (count - Weight.counter > 1000){
					System.out.println(count - Weight.counter);
					state = true;
			this.notifyAll();
				}
				while (state){
					try {
				        this.wait();
				      } catch(InterruptedException exc) {}
				}
					
				count ++;
				String[] data = s.nextLine().split("\\s+"); 
				
			Towary.listatowarow.add(new Towary(Integer.parseInt(data[0]), Double.parseDouble(data[1])));
			if(Towary.countob() % Towary.notifnewobj == 0){
				System.out.println("utworzono " + Towary.countob() + " obiektów");
				System.out.println("STATE " + state);
			}
				
			

				
				}
				}
			
			s.close();
			state = true;
			//notifyAll();
			System.out.println("-------------/n TOTAL : utworzono " + Towary.countob() + " obiektów");
		} catch (FileNotFoundException e) {
			}
		}

}
public class Weight implements Runnable{

static double actualweight;
static int counter = 0;

public void run(){
	
		
	synchronized (this){
while(!(Wczytywanie.state))
{

	try {
        wait();
      } catch(InterruptedException exc) {}
}

	for (Towary t : Towary.listatowarow){
		actualweight= actualweight + t.returnweight();
		counter++;
		if(counter % 100 == 0){
			System.out.println("zważono " + counter + " obiektów");
	}
		if (Wczytywanie.count - counter < 10 ) Wczytywanie.state = false;
		notifyAll();
	}
System.out.println ("policzono wage " + Towary.countob() +" towarów");
System.out.println("-------------/n TOTAL : waga " + actualweight);
}
}

}

 

public class Main {

  public static void main(String[] args)throws InterruptedException  {
  
	  (new Thread(new Wczytywanie())).start();
	 (new Thread(new Weight())).start();
		}
}
 

import java.util.ArrayList;
public class Towary {
int id_towaru;
double waga;
static int countobj = 0;
static int notifnewobj = 100;
static int notifnewweight = 100;
public static ArrayList<Towary> listatowarow = new ArrayList<Towary>();

public Towary(int id_towaru, double waga){
	this.id_towaru = id_towaru;
	this.waga=waga;
	countobj ++ ;
}
void add(int a, double b){
	listatowarow.add(new Towary(a, b));
}
public static int countob(){
	return countobj;
}

double returnweight(){
	return waga;
}

}


import java.io.File;
import java.util.Scanner;
import java.io.FileNotFoundException;
public class Wczytywanie implements Runnable {
	public static boolean state = false;
static int count = 0;
public static int actuallines = -1;
	
	public void run() {

	

		  Scanner s;
		try {

			s = new Scanner(new File("C:/Users/Janusz/Desktop/Towary.txt"));
			synchronized (Towary.listatowarow){
				
			while (s.hasNext()){
				if (count - Weight.counter > 299){
					state = true;
			Towary.listatowarow.notifyAll();
				}
				while (state){
					try {
						Towary.listatowarow.wait();
				      } catch(InterruptedException exc) {}
				}
					
				count ++;
				String[] data = s.nextLine().split("\\s+"); 
				
			Towary.listatowarow.add(new Towary(Integer.parseInt(data[0]), Double.parseDouble(data[1])));
			if(Towary.countob() % Towary.notifnewobj == 0){
				System.out.println("utworzono " + Towary.countob() + " obiektów");
			}
				
			

				
				}
				
			actuallines = Towary.countob();
			s.close();
			state = true;
			Towary.listatowarow.notifyAll();
			System.out.println("-------------/n TOTAL : utworzono " + Towary.countob() + " obiektów");
			}
		} catch (FileNotFoundException e) {
			}
		}

}


public class Weight implements Runnable{

static double actualweight;
static int counter = 0;
boolean finish = false;
public void run(){
	
	
	synchronized (Towary.listatowarow){
		while(!(Wczytywanie.state))
{

	try {
		Towary.listatowarow.wait();
      } catch(InterruptedException exc) {}
}

	for (Towary t : Towary.listatowarow){
		while((counter == (Towary.countob()-1)))
		{
			Wczytywanie.state = false;
			Towary.listatowarow.notifyAll();
			try {
				
				Towary.listatowarow.wait();
				
		      } catch(InterruptedException exc) {}
				
		}
		counter++;
		actualweight= actualweight + t.returnweight();
		
		if(counter % Towary.notifnewweight == 0){
			System.out.println("zważono " + counter + " obiektów");
		}
	}
	}


	System.out.println ("policzono wage " + Towary.countob() +" towarów");
	System.out.println("-------------/n TOTAL : waga " + actualweight);
}
}

Towary.listatowarow