0

OSGi モジュールとして次のコードがあります。

実行すると、ロガーが設定されたというメッセージが表示されます。

UdpListener > setStoreLog: 'com.mine.logger.internal.storeindb.StoreLog@1c6f579'

しかしその直後、run() 関数のループは storeLog が空であることを示しています。

ERROR > UdpListener > run > storeLog is not available.

何が間違っている可能性がありますか？

これがスレッドで実行されているという事実でしょうか？

package com.mine.logger.internal.udp;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.Date;

import com.mine.logger.storeindb.IStoreLog;

public class UdpListener extends Thread
{
    private int port;

    private IStoreLog storeLog;

    public void setStoreLog(IStoreLog value)
    {
        this.storeLog = value;
        System.out.println("UdpListener > setStoreLog: '" + this.storeLog.toString() + "'");
    }

    public void unsetStoreLog(IStoreLog value)
    {
        if (this.storeLog == value) {
            this.storeLog = null;
        }
        System.out.println("UdpListener > unsetStoreLog");
    }

    public UdpListener() 
    {
        // public, no-args constructor needed for Declarative Services !!!
    }

    public UdpListener(int port) 
    {
        this.port = port;
    }

    public void run()
    {
        startListener();
    }

    private void startListener()
    {
        try {
            // send command
            DatagramSocket socket = new DatagramSocket(port);

            while (true)
            {
                byte[] b = new byte[1000];
                DatagramPacket recvdPacket = new DatagramPacket(b, b.length);
                socket.receive(recvdPacket);

                System.out.println("UdpListener: Packet received. " + (new String(b)));

                try
                {
                    if (this.storeLog != null)
                        this.storeLog.doStore(new Date(), InetAddress.getByName("0.0.0.0"), port, 1, "UDP", b);
                    else
                        System.err.println("ERROR > UdpListener > run > storeLog is not available.");
                }
                catch (Exception e)
                {
                    System.err.println("ERROR > UdpListener > run > storeLog > Exception: " + e.toString());
                }
            }
        } catch (SocketException e) {
            System.out.println("ERROR > UdpListener > run > SocketException: " + e.getMessage());
        } catch (IOException e) {
            System.out.println("ERROR > UdpListener > run > IOException: " + e.getMessage());
        } catch (Exception e) {
            System.out.println("ERROR > UdpListener > run > Exception: " + e.getMessage());
        }
    }
}
4

2 に答える 2

2

あなたのコードはスレッドセーフではありません。storeLog フィールドは、同期なしで複数のスレッドによって読み書きされます。複数のスレッドによって読み取りと書き込みが行われる可変フィールドがある場合は、そのフィールドが読み取りと書き込みの両方で常に安全にアクセスされるようにする必要があります。Java コードを書いている人には、すばらしい本 Java Concurrency in Practice http://www.javaconcurrencyinpractice.com/を強くお勧めします。

于 2010-12-09T14:09:59.170 に答える
-2

storelog を別のクラスに移動することで解決

于 2010-12-09T13:54:28.717 に答える